Browse Source

fix: 测试

许家凯 4 years ago
parent
commit
715757e438
1 changed files with 10 additions and 3 deletions
  1. 10 3
      src/main/scala/com/winhc/bigdata/spark/utils/CompanySummaryPro.scala

+ 10 - 3
src/main/scala/com/winhc/bigdata/spark/utils/CompanySummaryPro.scala

@@ -191,6 +191,14 @@ case class CompanySummaryPro(s: SparkSession,
            |    summary_tab
            |""".stripMargin)
         .save2HBase("COMPANY_SUMMARY", "cid", writF)*/
+      create_or_replace_summary(target_tab)
+      sql(
+        s"""
+           |INSERT ${if (isWindows) "INTO" else "OVERWRITE"} TABLE $target_tab
+           |SELECT *
+           |FROM
+           |    summary_tab
+           |""".stripMargin)
     } else {
       create_or_replace_summary(target_tab)
       sql(
@@ -227,10 +235,9 @@ object CompanySummaryPro {
       , project = "winhc_eci_dev"
       , tableName = "company_judicial_assistance_list"
       , cidField = "split(rowkey,'_')[0]"
-      , groupByInfo = null
       , where = "deleted = 0"
-      , sortField = null)
-      .calc(is_inc = false, target_tab = "winhc_eci_dev.xjk_tmp_summary")
+      )
+      .calc(is_inc = true, target_tab = "winhc_eci_dev.xjk_tmp_summary")
 
     spark.stop()
   }