|
|
@@ -62,6 +62,11 @@ object args_job {
|
|
|
, 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")
|
|
|
+
|
|
|
+ , args_job(tableName = "company_lawsuit"
|
|
|
+ , explode = "LATERAL VIEW explode(jsonall_2_array('$.litigant_id', concat_ws('\u0001', defendant_info, plaintiff_info, litigant_info)) ) key AS key_no"
|
|
|
+ , keyno = "key_no"
|
|
|
+ )
|
|
|
)
|
|
|
|
|
|
def get_args_company_job(tn: String): args_job = {
|
|
|
@@ -209,7 +214,7 @@ object lookup_tab_pid {
|
|
|
def main(args: Array[String]): Unit = {
|
|
|
if (args.size != 2) {
|
|
|
println(args.mkString(","))
|
|
|
- println("please set project ds.")
|
|
|
+ println("please set project tn.")
|
|
|
sys.exit(-1)
|
|
|
}
|
|
|
val Array(project, tn) = args
|
xufei