|
@@ -3,14 +3,14 @@
|
|
package com.winhc.bigdata.spark.ng.dynamic.handle
|
|
package com.winhc.bigdata.spark.ng.dynamic.handle
|
|
|
|
|
|
import com.winhc.bigdata.spark.implicits.MapHelper._
|
|
import com.winhc.bigdata.spark.implicits.MapHelper._
|
|
-import com.winhc.bigdata.spark.ng.dynamic.utils.{DailyAggHandle, SimpleDailyDynamic}
|
|
|
|
|
|
+import com.winhc.bigdata.spark.ng.dynamic.utils.{ComplexDailyDynamic, DailyAggHandle, SimpleDailyDynamic}
|
|
import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
|
|
import com.winhc.bigdata.spark.ng.dynamic.{AssociationEntityInfo, NgCompanyRiskLevelType}
|
|
|
|
|
|
/**
|
|
/**
|
|
* @author: XuJiakai
|
|
* @author: XuJiakai
|
|
* @date: 2021/6/29 15:07
|
|
* @date: 2021/6/29 15:07
|
|
*/
|
|
*/
|
|
-case class company_license_creditchina(is_inc:Boolean) extends DailyAggHandle with SimpleDailyDynamic {
|
|
|
|
|
|
+case class company_license_creditchina(is_inc:Boolean) extends DailyAggHandle with ComplexDailyDynamic {
|
|
|
|
|
|
|
|
|
|
override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
|
|
override def getAssociationEntityInfo(new_data: Map[String, String]): Seq[AssociationEntityInfo] = {
|