Commit 5780f800 authored by 王志伟's avatar 王志伟

新统计需求

parent 92953376
......@@ -259,6 +259,7 @@ object diary_exposure {
val final_cid_city = diary_id_temp.join(df_cid_city,Seq("diary_id"),"left_outer").na.drop()
final_cid_city.show()
final_cid_city.groupBy("name").count().show(30)
......
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