Skip to content

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

新统计需求

parent 9b75a107
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
eda/feededa/src/main/scala/com/gmei/strategy_other.scala
View file @ f96b177a
......@@ -258,9 +258,9 @@ object diary_exposure {
val df_cid_city = cid_city.join(city_df,Seq("tag_id"),"left_outer").na.drop()
.drop("tag_id")
val final_cid_city = diary_id_temp.join(df_cid_city,Seq("diary_id"),"left_outer").na.drop()
val final_cid_city = diary_id_temp.join(df_cid_city,Seq("diary_id"),"left_outer")
final_cid_city.show()
final_cid_city.groupBy("name").count().orderBy(desc("count")).show(40)
final_cid_city.groupBy("name").count().orderBy(desc("count")).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