Commit 11fb40f5 authored by 王志伟's avatar 王志伟

修改统计参数

parent 840f3693
......@@ -73,7 +73,7 @@ object app_list {
//以上为udf函数
//获取策略命中用户device_id
/* //获取策略命中用户device_id
val app_list = sc.sql(
s"""
|select distinct(cl_id) as device_id, user_id as user_id, params['installed_app_info'] as app_list
......@@ -103,6 +103,22 @@ object app_list {
temp.show()
GmeiConfig.writeToJDBCTable(tempp, "device_id_coincidence", SaveMode.Append)
*/
//所有获得应用列表的用户device_id
val app_list_all = sc.sql(
s"""
|select '${partition_date}' as stat_date,distinct(cl_id) as device_id, user_id as user_id
|from online.tl_hdfs_maidian_view
|where action="user_installed_all_app_info"
|and partition_date = '${partition_date}'
|and device_id not in (select device_id from bl_device_list)
|and device_id not in (select device_id from blacklist)
""".stripMargin
)
GmeiConfig.writeToJDBCTable(app_list_all, "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