Commit 0124d891 authored by 王志伟's avatar 王志伟

区别新老客户

parent 23386807
...@@ -69,7 +69,7 @@ object testt { ...@@ -69,7 +69,7 @@ object testt {
|AND pv_ratio >= 0.95 |AND pv_ratio >= 0.95
""".stripMargin """.stripMargin
) )
// agency_id.show() agency_id.show()
agency_id.createOrReplaceTempView("agency_id") agency_id.createOrReplaceTempView("agency_id")
//每日新用户 //每日新用户
val device_id_newUser = sc.sql( val device_id_newUser = sc.sql(
...@@ -87,6 +87,7 @@ object testt { ...@@ -87,6 +87,7 @@ object testt {
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
""".stripMargin """.stripMargin
) )
device_id_newUser.show()
device_id_newUser.createOrReplaceTempView("device_id_new") device_id_newUser.createOrReplaceTempView("device_id_new")
//每日老用户 //每日老用户
...@@ -105,6 +106,7 @@ object testt { ...@@ -105,6 +106,7 @@ object testt {
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
""".stripMargin """.stripMargin
) )
device_id_oldUser.show()
device_id_oldUser.createOrReplaceTempView("device_id_old") device_id_oldUser.createOrReplaceTempView("device_id_old")
......
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