Commit 5797e398 authored by 王志伟's avatar 王志伟

跑波动原因数据

parent 9f72344a
......@@ -529,8 +529,8 @@ object alpha_ctr {
import sc.implicits._
val stat_date = GmeiConfig.getMinusNDate(1)
// val stat_date = param.date
// val stat_date = GmeiConfig.getMinusNDate(1)
val stat_date = param.date
//println(param.date)
val partition_date = stat_date.replace("-","")
......@@ -614,8 +614,8 @@ object alpha_ctr {
// GmeiConfig.writeToJDBCTable("jerry.jdbcuri",result, table="alpha_ctr",SaveMode.Append)
// GmeiConfig.writeToJDBCTable(result, "alpha_ctr", SaveMode.Append)
GmeiConfig.writeToJDBCTable("jdbc:mysql://172.16.40.158:4000/jerry_prod?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",result, table="alpha_ctr",SaveMode.Append)
println("写入完成")
// GmeiConfig.writeToJDBCTable("jdbc:mysql://172.16.40.158:4000/jerry_prod?user=root&password=3SYz54LS9#^9sBvC&rewriteBatchedStatements=true",result, table="alpha_ctr",SaveMode.Append)
// println("写入完成")
......@@ -624,7 +624,7 @@ object alpha_ctr {
|select '${stat_date}' as stat_date,count(DISTINCT(device_id)) as device_num
|from ml.ML_ALPHA_C_CT_DV_DEVICE_DIMEN_D
|where partition_day='${partition_date}'
|and is_today_active="1"
|and is_today_active='true'
""".stripMargin
)
device_num_count.show()
......
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