Browse Source

增量处理spark程序对送达公告的单独配置

晏永年 4 years ago
parent
commit
6562bd78ab

+ 1 - 0
src/main/scala/com/winhc/bigdata/spark/utils/CompanyIncrForCidsUtils.scala

@@ -23,6 +23,7 @@ case class CompanyIncrForCidsUtils(s: SparkSession,
 
   val tabMapping =
     Map("company_court_open_announcement" -> ("litigant_cids", ";") //开庭公告
+      ,"company_send_announcement" -> ("litigant_cids",",")//送达公告
     )
 
   val funMap =