计算多天的推荐重复问题

e49d623c · 王志伟 · 8d697a63 · e49d623c
Commit e49d623c authored Jan 16, 2019 by 王志伟
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

temp_count.scala eda/feededa/src/main/scala/com/gmei/temp_count.scala +2 -1

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/temp_count.scala
+++ b/eda/feededa/src/main/scala/com/gmei/temp_count.scala
@@ -324,7 +324,8 @@ object Repeated_content_recommendation_moreday {

      val count = sc.sql(
        s"""
-           |select count(*) from exp_diary
+           |select device_id,concat_ws(',',collect_set(expoure_diary)) from exp_diary
+           |group by device_id
         """.stripMargin
      )
      count.show()