Skip to content

F
ffm-baseline
Commit 70dab241 authored by 王志伟's avatar 王志伟
Browse files
Options

重新统计alpha

parent 1482f4df
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
eda/feededa/src/main/scala/com/gmei/temp_analysis.scala
View file @ 70dab241
...@@ -639,7 +639,7 @@ object alpha_ctr { ...@@ -639,7 +639,7 @@ object alpha_ctr {
val device_num_count = sc.sql( val device_num_count = sc.sql(
s""" s"""
|select '${stat_date}' as stat_date,count(DISTINCT(device_id)) |select '${stat_date}' as stat_date,count(DISTINCT(device_id))
|from ML_ALPHA_C_CT_DV_DEVICE_DIMEN_D |from ml.ML_ALPHA_C_CT_DV_DEVICE_DIMEN_D
|where partition_day='${partition_date}' |where partition_day='${partition_date}'
|and is_today_active="1" |and is_today_active="1"
""".stripMargin """.stripMargin
...@@ -649,7 +649,7 @@ object alpha_ctr { ...@@ -649,7 +649,7 @@ object alpha_ctr {
val duration_device=sc.sql( val duration_device=sc.sql(
s""" s"""
|select '${stat_date}' as stat_date,sum(user_duration)/count(DISTINCT(device_id)) |select '${stat_date}' as stat_date,sum(user_duration)/count(DISTINCT(device_id))
|from ML_ALPHA_C_CT_DV_DEVICE_INDIC_INC_D |from ml.ML_ALPHA_C_CT_DV_DEVICE_INDIC_INC_D
|WHERE partition_day='${partition_date}' |WHERE partition_day='${partition_date}'
|and open_times!="0" |and open_times!="0"
""".stripMargin """.stripMargin
......
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