|
@@ -3,7 +3,7 @@ package com.winhc.bigdata.spark.jobs
|
|
|
import com.winhc.bigdata.spark.config.EsConfig
|
|
|
import com.winhc.bigdata.spark.udf.BaseFunc
|
|
|
import com.winhc.bigdata.spark.utils.BaseUtil.isWindows
|
|
|
-import com.winhc.bigdata.spark.utils.{BaseUtil, LoggingUtils, MaxComputer2Phoenix, SparkUtils}
|
|
|
+import com.winhc.bigdata.spark.utils.{BaseUtil, CompanyIncSummary, LoggingUtils, MaxComputer2Phoenix, SparkUtils}
|
|
|
import org.apache.spark.internal.Logging
|
|
|
import org.apache.spark.sql.SparkSession
|
|
|
|
|
@@ -172,7 +172,7 @@ object inc_company_equity_info {
|
|
|
, "CONCAT_WS('_',cid,main_id)").syn()
|
|
|
import com.winhc.bigdata.spark.implicits.DataFrame2HBaseHelper._
|
|
|
|
|
|
- //todo 没有写出摘要
|
|
|
+ CompanyIncSummary(spark, project, "company_equity_info_list", "cid", Seq("cid", "main_id")).calc
|
|
|
|
|
|
val outFields = getColumns("winhc_eci_dev.inc_ads_company_equity_info").map(_.toUpperCase)
|
|
|
sql(
|