Commit 96a78883 authored by 王志伟's avatar 王志伟

smart_rank 相关的统计指标

parent f00d1cf6
......@@ -625,7 +625,6 @@ object smart_rank_count {
|and city_id is not null
""".stripMargin
)
user_city_meigou_view.show(80)
user_city_meigou_view.createOrReplaceTempView("user_city_meigou_view")
val meigou_city = sc.sql(
......@@ -639,7 +638,6 @@ object smart_rank_count {
|and d.partition_date='20181227'
""".stripMargin
)
meigou_city.show()
meigou_city.createOrReplaceTempView("meigou_city")
......@@ -651,21 +649,40 @@ object smart_rank_count {
|on a.meigou_id=b.meigou_id
""".stripMargin
)
meigou_pv_tongcheng.show()
meigou_pv_tongcheng.createOrReplaceTempView("meigou_pv_tongcheng")
val meigou_pv_count = sc.sql(
s"""
|select meigou_city,count(device_id) as meigou_pv,count(distinct(device_id)) as meigou_device_num,
|from meigou_pv_tongcheng
|where device_city=meigou_city
|group by meigou_city
""".stripMargin
)
meigou_pv_count.show()
// val zixun_pv = sc.sql(
// val zixun_meigou_view = sc.sql(
// s"""
// |select cl_id,city_id,params['service_id'] as meigou_id
// |select cl_id as device_id,city_id as device_city,params['service_id'] as meigou_id
// |from online.tl_hdfs_maidian_view
// |where partition_date > '20171118'
// |where partition_date >= '20181201'
// |and action = 'welfare_detail_click_message'
// """.stripMargin
// )
// zixun_pv.show(80)
// zixun_meigou_view.show(80)
// zixun_meigou_view.createOrReplaceTempView("zixun_meigou_view")
// val zixun_meigou_tongcheng = sc.sql(
// s"""
// |select a.device_id,a.device_city,a.meigou_id,b.meigou_city
// |from zixun_meigou_view a
// |left join meigou_city b
// |on a.meigou_id=b.meigou_id
// """.stripMargin
// )
// zixun_meigou_tongcheng.show(80)
......
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