소스 검색

feat: 过滤天眼查主要成员增量职位未知情况

许家凯 2 년 전
부모
커밋
5da20f89ed
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      src/main/scala/com/winhc/bigdata/spark/ng/jobs/V7DataCompare.scala

+ 1 - 0
src/main/scala/com/winhc/bigdata/spark/ng/jobs/V7DataCompare.scala

@@ -229,6 +229,7 @@ case class V7DataCompare(s: SparkSession
            |       select *
            |       from   winhc_eci_dev.inc_ods_$tn
            |       where  ds = '${BaseUtil.getYesterday()}'
+           |       and    staff_type <> '未知'
            |) as gt1
            |left join (
            |       select *