Skip to content

F
ffm-baseline
Commit fbe1d20d authored by 高雅喆's avatar 高雅喆
Browse files
Options

add esmm data

parent 1fa6bca4
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
eda/feededa/src/main/scala/com/gmei/EsmmData.scala
View file @ fbe1d20d
...@@ -55,7 +55,7 @@ object EsmmData { ...@@ -55,7 +55,7 @@ object EsmmData {
println(stat_date) println(stat_date)
val imp_data = sc.sql( val imp_data = sc.sql(
s""" s"""
|select stat_date,device_id,city_id as ucity_id, |select distinct stat_date,device_id,city_id as ucity_id,
| cid_id,diary_service_id | cid_id,diary_service_id
|from data_feed_exposure |from data_feed_exposure
|where cid_type = 'diary' |where cid_type = 'diary'
...@@ -69,7 +69,7 @@ object EsmmData { ...@@ -69,7 +69,7 @@ object EsmmData {
val clk_data = sc.sql( val clk_data = sc.sql(
s""" s"""
|select stat_date,device_id,city_id as ucity_id, |select distinct stat_date,device_id,city_id as ucity_id,
| cid_id,diary_service_id | cid_id,diary_service_id
|from data_feed_click |from data_feed_click
|where cid_type = 'diary' |where cid_type = 'diary'
...@@ -92,7 +92,7 @@ object EsmmData { ...@@ -92,7 +92,7 @@ object EsmmData {
val stat_date_not = GmeiConfig.getMinusNDate(14).replace("-","") val stat_date_not = GmeiConfig.getMinusNDate(14).replace("-","")
val cvr_data = sc.sql( val cvr_data = sc.sql(
s""" s"""
|select |select distinct
| from_unixtime(unix_timestamp('${stat_date_not}' ,'yyyyMMdd'), 'yyyy-MM-dd') as stat_date, | from_unixtime(unix_timestamp('${stat_date_not}' ,'yyyyMMdd'), 'yyyy-MM-dd') as stat_date,
| cl_id as device_id,city_id as ucity_id, | cl_id as device_id,city_id as ucity_id,
| params["referrer_id"] as cid_id,params["business_id"] as diary_service_id | params["referrer_id"] as cid_id,params["business_id"] as diary_service_id
......
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