Skip to content

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

修复bug

parent f02bea40
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 6 deletions
eda/feededa/src/main/scala/com/gmei/testt.scala
View file @ f160254a
...@@ -133,7 +133,7 @@ object testt { ...@@ -133,7 +133,7 @@ object testt {
diary_meigou_temp.createOrReplaceTempView("diary_meigou_temp") diary_meigou_temp.createOrReplaceTempView("diary_meigou_temp")
val diary_meigou_device = sc.sql( val diary_meigou_device = sc.sql(
s""" s"""
|select device_id |select dt.device_id
|from diary_meigou_temp dt left join blacklist |from diary_meigou_temp dt left join blacklist
|on dt.device_id = blacklist.device_id |on dt.device_id = blacklist.device_id
|where blacklist.device_id is null |where blacklist.device_id is null
...@@ -189,7 +189,7 @@ object testt { ...@@ -189,7 +189,7 @@ object testt {
val diary_clk_device = sc.sql( val diary_clk_device = sc.sql(
s""" s"""
|select device_id |select dt.device_id
|from diary_clk_temp dt left join blacklist |from diary_clk_temp dt left join blacklist
|on dt.device_id = blacklist.device_id |on dt.device_id = blacklist.device_id
|where blacklist.device_id is null |where blacklist.device_id is null
...@@ -246,7 +246,7 @@ object testt { ...@@ -246,7 +246,7 @@ object testt {
val diary_expoure_device = sc.sql( val diary_expoure_device = sc.sql(
s""" s"""
|select device_id |select dt.device_id
|from diary_expoure_temp dt left join blacklist |from diary_expoure_temp dt left join blacklist
|on dt.device_id = blacklist.device_id |on dt.device_id = blacklist.device_id
|where blacklist.device_id is null |where blacklist.device_id is null
...@@ -302,10 +302,10 @@ object testt { ...@@ -302,10 +302,10 @@ object testt {
val search_device = sc.sql( val search_device = sc.sql(
s""" s"""
|select device_id |select dt.device_id
|from search_device_temp dt left join blacklist |from search_device_temp dt left join blacklist
|on dt.device_id = blacklist.device_id |on dt.device_id = blacklist.device_id
|where blacklist.device_id is null |where blacklist.device_id is null
""".stripMargin """.stripMargin
) )
search_device.createOrReplaceTempView("search_device") search_device.createOrReplaceTempView("search_device")
...@@ -343,7 +343,7 @@ object testt { ...@@ -343,7 +343,7 @@ object testt {
val log_device = sc.sql( val log_device = sc.sql(
s""" s"""
|select device_id |select dt.device_id
|from log_device_temp dt left join blacklist |from log_device_temp dt left join blacklist
|on dt.device_id = blacklist.device_id |on dt.device_id = blacklist.device_id
|where blacklist.device_id is null |where blacklist.device_id is null
......
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