|
@@ -106,7 +106,7 @@ case class CompanyIndexJob(s: SparkSession,
|
|
spark.udf.register("get_amount", RegCapitalAmount.getAmount _)
|
|
spark.udf.register("get_amount", RegCapitalAmount.getAmount _)
|
|
}
|
|
}
|
|
|
|
|
|
- private val target_tab = "winhc_ng.out_company_v8_index_test"
|
|
|
|
|
|
+ private val target_tab = "winhc_ng.out_company_v8_index"
|
|
|
|
|
|
|
|
|
|
private val org_prefix = "ads"
|
|
private val org_prefix = "ads"
|