ソースを参照

fix: 融资变化触发索引更新

许家凯 2 年 前
コミット
252d20dbf8

+ 4 - 0
src/main/scala/com/winhc/bigdata/spark/ng/jobs/CompanyIndexJob.scala

@@ -177,6 +177,10 @@ case class CompanyIndexJob(s: SparkSession,
          |            SELECT  DISTINCT company_id
          |            FROM    winhc_ng.inc_${org_prefix}_company_app_info
          |            WHERE   ds > '$target_ds'
+         |            UNION ALL
+         |            SELECT  DISTINCT company_id
+         |            FROM    winhc_ng.inc_${org_prefix}_company_finance
+         |            WHERE   ds > '$target_ds'
          |        )
          |""".stripMargin)
       .cache()