最近做一个oracle项目迁移工作,跟着spark架构师学着做,进行一些方法的总结。
1、首先,创建SparkSession对象(老版本为sparkContext) val session =
SparkSession.builder().appName("app1").getOrCreate()
2、数据的更新时间配置表,选用mysql,就是说每次结果数据计算写入mysql后,还会将此次数据的更新时间写入数据配置表。
【mysql】 【Oracle】 【配置】 【同步】 【string】 …
Apr
30
2017
Apr
28
2017
Apr
21
2017
Apr
19
2017
Apr
15
2017
Apr
01
2017
Mar
29
2017
Mar
24
2017
Mar
23
2017
Mar
21
2017