소스 검색

恢复上个版本

xufei 4 년 전
부모
커밋
18f0b0d8cb
1개의 변경된 파일2개의 추가작업 그리고 11개의 파일을 삭제
  1. 2 11
      src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPre12.scala

+ 2 - 11
src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPre12.scala

@@ -74,17 +74,8 @@ case class JudicialCaseRelationPre12(s: SparkSession, project: String
          |         ,case_create_time as date
          |         ,rowkey as detail_id
          |         ,exec_amount as case_amt
-         |      from
-         |      (
-         |        select case_no,name,court_name,case_create_time,rowkey,update_time,exec_amount
-         |        from $project.ads_company_zxr_final_case
-         |        where length(case_no) > 0 and ds > '0'
-         |        union all
-         |        select case_no,name,court_name,case_create_time,rowkey,update_time,exec_amount
-         |        from $project.inc_ads_company_zxr_final_case
-         |        where length(case_no) > 0 and ds > '0'
-         |      )
-         |
+         |      from $project.inc_ads_company_zxr_final_case
+         |      where length(case_no) > 0 and ds > '0'
          |      union all
          |      select
          |         md5(cleanup(case_no)) as judicase_id