Ver código fonte

fix: 限高改rowkey规则

许家凯 3 anos atrás
pai
commit
ce139a2dda

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

@@ -44,8 +44,8 @@ object args_company_job {
       , is_super_filter = false
       , where = "case_no_trim(case_no) is not null and name is not null"
     )
-    , args_company_job("company_zxr_restrict", Seq("case_no", "person_name")
-      , rowkey_udf = "md5(cleanup(concat_ws('',case_no,person_name )))"
+    , args_company_job("company_zxr_restrict", Seq("case_no", "person_name","company_name")
+      , rowkey_udf = "md5(cleanup(concat_ws('',case_no,person_name,company_name )))"
       , is_super_filter = false
       , verify_company_id = false
       , where = "case_no_trim(case_no) is not null and person_name is not null and length(trim(person_name))>=2 "