Commit db1a1817 authored by 高雅喆's avatar 高雅喆

change sql

parent a5904974
......@@ -198,8 +198,7 @@ object Main {
|on a.cid = b.cid
|where b.similarity_cid is not null
""".stripMargin
)
device_id.na.fill(Map("city_id" -> "beijing"))
).na.fill(Map("city_id" -> "beijing"))
device_id.show()
val device_queue = device_id.rdd.map {item =>
......
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