|
@@ -14,8 +14,8 @@ import scala.collection.mutable
|
|
|
* @Date: 2020/9/27 11:41
|
|
|
* @Description: 其它几个维度司法案件前置处理
|
|
|
*/
|
|
|
-case class JCR_pre3(s: SparkSession,
|
|
|
- project: String //表所在工程名
|
|
|
+case class JudicialCaseRelationPre39(s: SparkSession,
|
|
|
+ project: String //表所在工程名
|
|
|
) extends LoggingUtils with Logging with BaseFunc with CompanyMapping {
|
|
|
@(transient@getter) val spark: SparkSession = s
|
|
|
|
|
@@ -154,7 +154,7 @@ case class JCR_pre3(s: SparkSession,
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-object JCR_pre3 {
|
|
|
+object JudicialCaseRelationPre39 {
|
|
|
def main(args: Array[String]): Unit = {
|
|
|
val config = mutable.Map(
|
|
|
"spark.hadoop.odps.project.name" -> "winhc_eci_dev",
|
|
@@ -162,7 +162,7 @@ object JCR_pre3 {
|
|
|
)
|
|
|
val spark: SparkSession = SparkUtils.InitEnv(this.getClass.getSimpleName, config)
|
|
|
|
|
|
- JCR_pre3(s = spark, project = "winhc_eci_dev").company_dishonest_info(false)
|
|
|
+ JudicialCaseRelationPre39(s = spark, project = "winhc_eci_dev").company_dishonest_info(false)
|
|
|
spark.stop()
|
|
|
}
|
|
|
}
|