소스 검색

fix(company_jobs): 添加迁移公司银行账户维度到v8任务

JimZhang 3 년 전
부모
커밋
1161e502bf
1개의 변경된 파일4개의 추가작업 그리고 0개의 파일을 삭제
  1. 4 0
      src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

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

@@ -413,6 +413,10 @@ object args_company_job {
       , rowkey_udf = "md5(cleanup(concat_ws('', company_id, change_item, split_date(cast(change_time as String)))))"
       , is_super_filter = false
     )
+    , args_company_job("company_account_with_bank", Seq.empty
+      , rowkey_udf = "company_id"
+      , is_super_filter = false
+    )
   )
 
   def get_args_company_job(tn: String): args_company_job = {