|
@@ -26,6 +26,8 @@ case class deadbeat_info(s: SparkSession,
|
|
|
private val filter_ele = Seq(
|
|
|
"company_dishonest_info"
|
|
|
, "company_dishonest_info_person"
|
|
|
+ , "company_zxr_person"
|
|
|
+ , "company_zxr"
|
|
|
)
|
|
|
|
|
|
private def is_con(s: String): Boolean = {
|
|
@@ -37,10 +39,23 @@ case class deadbeat_info(s: SparkSession,
|
|
|
|
|
|
private val m = Map("company_dishonest_info" -> "失信人"
|
|
|
, "company_dishonest_info_person" -> "失信人"
|
|
|
+ , "company_zxr" -> "执行人"
|
|
|
+ , "company_zxr_person" -> "执行人"
|
|
|
+ , "company_zxr_final_case" -> "终本案件"
|
|
|
+ , "company_zxr_final_case_person" -> "终本案件"
|
|
|
+ , "company_zxr_restrict" -> "限制高消费"
|
|
|
+ , "company_zxr_restrict_person" -> "限制高消费"
|
|
|
)
|
|
|
|
|
|
private val ids_m = Map("company_dishonest_info" -> "1"
|
|
|
- , "company_dishonest_info_person" -> "2")
|
|
|
+ , "company_dishonest_info_person" -> "2"
|
|
|
+ , "company_zxr" -> "3"
|
|
|
+ , "company_zxr_person" -> "4"
|
|
|
+ , "company_zxr_final_case" -> "5"
|
|
|
+ , "company_zxr_final_case_person" -> "6"
|
|
|
+ , "company_zxr_restrict" -> "7"
|
|
|
+ , "company_zxr_restrict_person" -> "8"
|
|
|
+ )
|
|
|
|
|
|
class person_agg_label extends UserDefinedAggregateFunction {
|
|
|
|