|
@@ -194,7 +194,7 @@ case class CompanySummaryPro(s: SparkSession,
|
|
|
|
|
|
|
|
|
if (StringUtils.isEmpty(target_tab)) {
|
|
|
- /*import com.winhc.bigdata.spark.implicits.DataFrame2HBaseHelper._
|
|
|
+ import com.winhc.bigdata.spark.implicits.DataFrame2HBaseHelper._
|
|
|
val writF = getColumns("summary_tab").diff(Seq("cid"))
|
|
|
sql(
|
|
|
s"""
|
|
@@ -202,15 +202,15 @@ case class CompanySummaryPro(s: SparkSession,
|
|
|
|FROM
|
|
|
| summary_tab
|
|
|
|""".stripMargin)
|
|
|
- .save2HBase("COMPANY_SUMMARY", "cid", writF)*/
|
|
|
- create_or_replace_summary(target_tab)
|
|
|
+ .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)
|
|
|
+ |""".stripMargin)*/
|
|
|
} else {
|
|
|
create_or_replace_summary(target_tab)
|
|
|
sql(
|