Commit 35b7c0f1 authored by 高雅喆's avatar 高雅喆

change sql

parent db1a1817
...@@ -191,7 +191,7 @@ object Main { ...@@ -191,7 +191,7 @@ object Main {
val device_id = sc.sql( val device_id = sc.sql(
s""" s"""
|select a.device_id device_id,a.city_id city_id ,b.similarity_cid similarity_cid from |select a.device_id device_id,a.city_id city_id ,b.similarity_cid similarity_cid from
|(select device_id,city_id,first(cid) as cid from data_feed_click |(select device_id,first(city_id) as city_id,first(cid) as cid from data_feed_click
|where cid in (select cid from nd_cid_similarity_matrix) |where cid in (select cid from nd_cid_similarity_matrix)
|group by device_id order by time) a left join |group by device_id order by time) a left join
|nd_cid_similarity_matrix b |nd_cid_similarity_matrix b
......
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