Commit bce3237b authored by 王志伟's avatar 王志伟

修改统计参数

parent d7625a7e
...@@ -405,7 +405,7 @@ object coincidence_xinyang { ...@@ -405,7 +405,7 @@ object coincidence_xinyang {
val zixun_num_co = sc.sql( val zixun_num_co = sc.sql(
s""" s"""
|select count(distinct(ov.cl_id)) as zixun_num_all |select count(ov.cl_id) as zixun_num_all
|from online.tl_hdfs_maidian_view ov left join all_id |from online.tl_hdfs_maidian_view ov left join all_id
|on ov.cl_id = coincidence_id.device_id |on ov.cl_id = coincidence_id.device_id
|where partition_date >= '20180501' |where partition_date >= '20180501'
......
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