Explorar el Código

给下游添加case_no

晏永年 hace 4 años
padre
commit
17276f0eac

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/GraphX4Judicase.scala

@@ -101,7 +101,7 @@ case class GraphX4Judicase(s: SparkSession,
          |ON A.case_id=B.id
          |""".stripMargin)//.createOrReplaceTempView(s"tmp_graphx_$tableName")*/
       s"""INSERT ${if (isWindows) "INTO" else "OVERWRITE"} TABLE ${project}.ads_judicial_case_relation_graph
-         |SELECT B.id AS id, judicase_id, B.tn AS flag
+         |SELECT B.id AS id, judicase_id, case_no, B.tn AS flag
          |FROM tmp_edgelets_$tableName A
          |LEFT JOIN tmp_graphx_dwd_judicial_case B
          |ON A.id=B.id_Long