|
@@ -125,8 +125,8 @@ object args_company_job {
|
|
, explode_args("defendant_info", "$.litigant_id", "defendant_info_id_explode")
|
|
, explode_args("defendant_info", "$.litigant_id", "defendant_info_id_explode")
|
|
)
|
|
)
|
|
)
|
|
)
|
|
- , args_company_job("company_zxr_final_case", Seq("case_no")
|
|
|
|
- , rowkey_udf = "md5(cleanup(concat_ws('',case_no )))"
|
|
|
|
|
|
+ , args_company_job("company_zxr_final_case", Seq("case_no,name")
|
|
|
|
+ , rowkey_udf = "md5(cleanup(concat_ws('',case_no,name )))"
|
|
, is_super_filter = false
|
|
, is_super_filter = false
|
|
)
|
|
)
|
|
, args_company_job("company_tax_contravention", Seq("case_info", "company_id")
|
|
, args_company_job("company_tax_contravention", Seq("case_info", "company_id")
|
|
@@ -147,15 +147,15 @@ object args_company_job {
|
|
, id_user_defined_rowkey = true
|
|
, id_user_defined_rowkey = true
|
|
)
|
|
)
|
|
, args_company_job("company_mortgage_pawn", Seq("main_id", "pawn_name", "detail")
|
|
, args_company_job("company_mortgage_pawn", Seq("main_id", "pawn_name", "detail")
|
|
- , rowkey_udf = "md5(cleanup(concat_ws('',main_id,pawn_name,detail )))"
|
|
|
|
|
|
+ , rowkey_udf = "concat_ws('_', main_id, md5(cleanup(concat_ws('',pawn_name,detail ))) )"
|
|
, is_super_filter = false
|
|
, is_super_filter = false
|
|
)
|
|
)
|
|
, args_company_job("company_mortgage_change", Seq("main_id", "change_date", "change_content")
|
|
, args_company_job("company_mortgage_change", Seq("main_id", "change_date", "change_content")
|
|
- , rowkey_udf = "md5(cleanup(concat_ws('',main_id,split_date(cast(change_date as String)),change_content )))"
|
|
|
|
|
|
+ , rowkey_udf = "concat_ws('_', main_id, md5(cleanup(concat_ws('',split_date(cast(change_date as String)),change_content ))) )"
|
|
, is_super_filter = false
|
|
, is_super_filter = false
|
|
)
|
|
)
|
|
, args_company_job("company_mortgage_people", Seq("main_id")
|
|
, args_company_job("company_mortgage_people", Seq("main_id")
|
|
- , rowkey_udf = "md5(cleanup(concat_ws('',main_id)))"
|
|
|
|
|
|
+ , rowkey_udf = "concat_ws('_', main_id, md5(cleanup(concat_ws('',main_id))) )"
|
|
, is_super_filter = false
|
|
, is_super_filter = false
|
|
)
|
|
)
|
|
, args_company_job("company_double_random_check_info", Seq("check_task_num", "check_plan_num")
|
|
, args_company_job("company_double_random_check_info", Seq("check_task_num", "check_plan_num")
|
|
@@ -164,7 +164,7 @@ object args_company_job {
|
|
, id_user_defined_rowkey = true
|
|
, id_user_defined_rowkey = true
|
|
)
|
|
)
|
|
, args_company_job("company_double_random_check_result_info", Seq("main_id", "check_item", "check_result")
|
|
, args_company_job("company_double_random_check_result_info", Seq("main_id", "check_item", "check_result")
|
|
- , rowkey_udf = "md5(cleanup(concat_ws('',main_id,check_item,check_result)))"
|
|
|
|
|
|
+ , rowkey_udf = "concat_ws('_', main_id, md5(cleanup(concat_ws('',check_item,check_result))) )"
|
|
, is_super_filter = false
|
|
, is_super_filter = false
|
|
)
|
|
)
|
|
|
|
|