Commit b583dd87 authored by 王志伟's avatar 王志伟

repair bug

parent 954afd78
...@@ -279,7 +279,7 @@ object diary_exposure { ...@@ -279,7 +279,7 @@ object diary_exposure {
val final_cid_city = diary_id_temp.join(df_cid_city,Seq("diary_id"),"left_outer") val final_cid_city = diary_id_temp.join(df_cid_city,Seq("diary_id"),"left_outer")
final_cid_city.show() final_cid_city.show()
val df1=final_cid_city.groupBy("name").count().orderBy(desc("count")) val df1=final_cid_city.groupBy("name").count().orderBy(desc("count"))
df1.show(400) // df1.show(400)
//3.5星以上日记本的id //3.5星以上日记本的id
...@@ -289,7 +289,7 @@ object diary_exposure { ...@@ -289,7 +289,7 @@ object diary_exposure {
|from src_mimas_prod_api_diary |from src_mimas_prod_api_diary
|where content_level >=3.5 |where content_level >=3.5
|and doctor_id is not null |and doctor_id is not null
""".stripMargin """.stripMargin
) )
diary_id_temp2.createOrReplaceTempView("diary_id_temp2") diary_id_temp2.createOrReplaceTempView("diary_id_temp2")
...@@ -315,7 +315,7 @@ object diary_exposure { ...@@ -315,7 +315,7 @@ object diary_exposure {
val final_cid_city2 = diary_id_temp2.join(df_cid_city2,Seq("diary_id"),"left_outer") val final_cid_city2 = diary_id_temp2.join(df_cid_city2,Seq("diary_id"),"left_outer")
final_cid_city2.show() final_cid_city2.show()
val df2 =final_cid_city2.groupBy("name").count().orderBy(desc("count")) val df2 =final_cid_city2.groupBy("name").count().orderBy(desc("count"))
df2.show(400) // df2.show(400)
val df3 =df1.join(df2,Seq("name"),"left_outer") val df3 =df1.join(df2,Seq("name"),"left_outer")
df3.show(400) 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