Commit 31be6ef9 authored by 王志伟's avatar 王志伟

修改统计参数

parent 11fb40f5
...@@ -108,7 +108,7 @@ object app_list { ...@@ -108,7 +108,7 @@ object app_list {
//所有获得应用列表的用户device_id //所有获得应用列表的用户device_id
val app_list_all = sc.sql( val app_list_all = sc.sql(
s""" s"""
|select '${partition_date}' as stat_date,distinct(cl_id) as device_id, user_id as user_id |select distinct(cl_id) as device_id, user_id as user_id
|from online.tl_hdfs_maidian_view |from online.tl_hdfs_maidian_view
|where action="user_installed_all_app_info" |where action="user_installed_all_app_info"
|and partition_date = '${partition_date}' |and partition_date = '${partition_date}'
...@@ -116,8 +116,9 @@ object app_list { ...@@ -116,8 +116,9 @@ object app_list {
|and device_id not in (select device_id from blacklist) |and device_id not in (select device_id from blacklist)
""".stripMargin """.stripMargin
) )
val tempp_list=app_list_all.withColumn("stat_date",addCol(app_list_all("device_id")))
GmeiConfig.writeToJDBCTable(app_list_all, "device_id_applist", SaveMode.Append) GmeiConfig.writeToJDBCTable(tempp_list, "device_id_applist", SaveMode.Append)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment