增加维度

src/main/scala/com/winhc/bigdata/spark/ng/relation/lookup_tab_pid.scala

@@ -54,6 +54,14 @@ object args_job {
       , explode = "LATERAL VIEW explode( split(concat_ws('\u0001', limited_person_pid, executed_person_keyno),'\u0001') ) key AS keyno"
       , keyno = "keyno"
     )
+    , args_job(tableName = "company_punishment_info", keyno = "pid")
+    , args_job(tableName = "company_punishment_info_creditchina", keyno = "pid")
+    , args_job(tableName = "bankruptcy_open_case"
+      , explode = "LATERAL VIEW explode(jsonall_2_array('$.litigant_id', concat_ws('\u0001', applicant_info, respondent_info)) ) key AS key_no"
+      , keyno = "key_no")
+    , args_job(tableName = "company_judicial_assistance"
+      , explode = "LATERAL VIEW explode( split(concat_ws('\u0001', cg_assignee_id, cg_executed_person_id, gn_executed_person_id, lf_executed_person_id, fz_executed_person_id, executed_person_id),'\u0001') ) key AS key_no"
+      , keyno = "key_no")
   )
 
   def get_args_company_job(tn: String): args_job = {