Переглянути джерело

图处理添加被执、失信2个维度,ads_judicial_case_relation的id_1、id_2字段现有数据尾部追加2位数字标志:01:文书;02:被执;03:失信。

晏永年 4 роки тому
батько
коміт
357d167237

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

@@ -54,7 +54,14 @@ case class GraphX4Judicase(s: SparkSession,
         mp
       })
       .map(r => {
-      Row(r._1.toString, r._2("judicase_id"), "1")
+/*
+        ads_judicial_case_relation的id_1、id_2字段现有数据尾部追加2位数字标志:
+        01:文书;
+        02:被执;
+        03:失信。
+        ads_judicial_case_relation_graph表的flag字段与这2位数字对应
+*/
+      Row(r._1.toString, r._2("judicase_id"), r._1.toString.takeRight(2))
     })
     val schemaJust = StructType(Array(
       StructField("id", StringType),