Commit 05788a84 authored by 王志伟's avatar 王志伟

repair bug

parent b583dd87
......@@ -315,7 +315,6 @@ object diary_exposure {
val final_cid_city2 = diary_id_temp2.join(df_cid_city2,Seq("diary_id"),"left_outer")
final_cid_city2.show()
val df2 =final_cid_city2.groupBy("name").count().orderBy(desc("count"))
// df2.show(400)
val df3 =df1.join(df2,Seq("name"),"left_outer")
df3.show(400)
......
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