Bladeren bron

fix: 修改股权出质规则

许家凯 3 jaren geleden
bovenliggende
commit
2401234d25
1 gewijzigde bestanden met toevoegingen van 2 en 2 verwijderingen
  1. 2 2
      src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

+ 2 - 2
src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

@@ -51,8 +51,8 @@ object args_company_job {
       , where = "case_no_trim(case_no) is not null and person_name is not null and length(trim(person_name))>=2 "
     )
 
-    , args_company_job("company_equity_info", Seq("reg_number", "pledgee_info", "pledgor_info")
-      , rowkey_udf = "md5(cleanup(concat_ws('',reg_number,equity_info_rowkey(pledgee_info,pledgor_info)  )))"
+    , args_company_job("company_equity_info", Seq("reg_number", "pledgee_info", "pledgor_info","related_company_name")
+      , rowkey_udf = "md5(cleanup(concat_ws('',reg_number,equity_info_rowkey(pledgee_info,pledgor_info),related_company_name  )))"
       , is_super_filter = false
 
       , explode_args = Seq(