|
@@ -230,7 +230,7 @@ case class deadbeat_info(s: SparkSession,
|
|
|
mapTables("company_zxr") = ("rowkey", "cname", "card", "case_create_time", "deleted")
|
|
|
mapTables("company_dishonest_info") = ("rowkey", "name", "card_num", "pub_date", "status")
|
|
|
mapTables("company_zxr_final_case") = ("rowkey", "name", "identity_num", "case_create_time", "deleted")
|
|
|
- mapTables("company_zxr_restrict") = ("rowkey", "name", "identity_num", "case_create_time", "deleted")
|
|
|
+ mapTables("company_zxr_restrict") = ("rowkey", "name", "identity_num", "case_create_time", "status")
|
|
|
mapTables.foreach(m => {
|
|
|
spark.sparkContext.setJobDescription(s"查老赖(个人)数据预处理:${m._1}")
|
|
|
deadbeat_info_pre(spark, project = project, table = m._1, rowkey = m._2._1, cid = null, name = m._2._2, card_num = m._2._3, publish_date = m._2._4, deleted = m._2._5).calc()
|
|
@@ -312,7 +312,7 @@ case class deadbeat_info(s: SparkSession,
|
|
|
mapTables("company_zxr") = ("rowkey", "cids", "cname", "card", "case_create_time", "deleted")
|
|
|
mapTables("company_dishonest_info") = ("rowkey", "cid", "name", "card_num", "pub_date", "status")
|
|
|
mapTables("company_zxr_final_case") = ("rowkey", "cid", "name", "identity_num", "case_create_time", "deleted")
|
|
|
- mapTables("company_zxr_restrict") = ("rowkey", "cid", "name", "identity_num", "case_create_time", "deleted")
|
|
|
+ mapTables("company_zxr_restrict") = ("rowkey", "cid", "name", "identity_num", "case_create_time", "status")
|
|
|
mapTables.foreach(m => {
|
|
|
println(m)
|
|
|
spark.sparkContext.setJobDescription(s"查老赖(企业)数据预处理:${m._1}")
|