소스 검색

剔除deleted判断

xufei 3 년 전
부모
커밋
bfe202a7eb
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/CompanyWenshuDetailCombine.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/CompanyWenshuDetailCombine.scala

@@ -147,7 +147,7 @@ case class CompanyWenshuDetailCombine(s: SparkSession,
         |JOIN    (
         |           SELECT  cname,max(new_cid) new_cid
         |           FROM    winhc_eci_dev.base_company_mapping
-        |           WHERE   ds = '$mapDs' AND length(CLEANUP(cname)) > 4 AND deleted ='0' AND company_type not in ('2','8')
+        |           WHERE   ds = '$mapDs' AND length(CLEANUP(cname)) > 4 AND company_type not in ('2','8')
         |           GROUP BY  cname
         |        ) f
         |ON      CLEANUP(e.cname) = CLEANUP(f.cname)