markilue
/
self_example
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

用户画像example更新

This commit is contained in:
markilue 2022-05-16 13:43:34 +08:00
parent 115f0a9e9f
commit fda72667cb
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Big_data_example/user_profile/export-clickhouse/src/main/scala/com/atguigu/userprofile/app/TaskExportCkApp.scala
View File

@ -23,7 +23,7 @@ object TaskExportCkApp{
def main(args: Array[String]): Unit = { def main(args: Array[String]): Unit = {
//TODO 1 读取hive的宽表 读取成为Dataframe //TODO 1 读取hive的宽表 读取成为Dataframe
val sparkConf: SparkConf = new SparkConf().setAppName("task_export_app") .setMaster("local[*]") val sparkConf: SparkConf = new SparkConf().setAppName("task_export_app") //.setMaster("local[*]")
val sparkSession: SparkSession = SparkSession.builder().config(sparkConf).enableHiveSupport().getOrCreate() val sparkSession: SparkSession = SparkSession.builder().config(sparkConf).enableHiveSupport().getOrCreate()
val taskDate =args(1); val taskDate =args(1);