Explorar el Código

fix: 索引计算性能优化

许家凯 hace 3 años
padre
commit
3313e57b7f

+ 3 - 1
src/main/scala/com/winhc/bigdata/spark/ng/jobs/CompanyIndexJob.scala

@@ -258,7 +258,9 @@ case class CompanyIndexJob(s: SparkSession,
          |INSERT OVERWRITE TABLE $target_tab_simp PARTITION(ds='$target_ds')
          |SELECT ${getColumns(target_tab_simp).diff(Seq("ds")).mkString(",")}
          |FROM
-         |    out_company_index
+         |    $target_tab
+         |WHERE
+         |    ds='$target_ds'
          |""".stripMargin)
 
   }