提交 01e77068 编写于 作者: zhenxin.ma's avatar zhenxin.ma

DS层数据同步处理

上级 04f35261
......@@ -3,9 +3,10 @@ package com.data
import java.sql.{PreparedStatement, Timestamp}
import com.DateUtils
import com.config.{MySQLConfig, SyncDataConfig}
import com.mysql.jdbc.Driver
import com.utils.{JDBCUtil, MySQLConfig, MyUtil, SyncDataConfig}
import org.apache.spark.{SparkConf}
import com.utils.{JDBCUtil, MyUtil}
import org.apache.spark.SparkConf
import org.apache.spark.rdd.RDD
import org.apache.spark.sql.{DataFrame, Dataset, Row, RowFactory, SaveMode, SparkSession}
......
......@@ -3,7 +3,8 @@ package com.data
import java.sql.{PreparedStatement, Timestamp}
import com.DateUtils
import com.utils.{JDBCUtil, MySQLConfig, MyUtil, SyncDataConfig}
import com.config.{MySQLConfig, SyncDataConfig}
import com.utils.{JDBCUtil, MyUtil}
import org.apache.spark.SparkConf
import org.apache.spark.serializer.KryoSerializer
import org.apache.spark.sql.{DataFrame, Dataset, SaveMode, SparkSession}
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册