统计多天重复日记数量

eda/feededa/src/main/scala/com/gmei/temp_count.scala

@@ -304,7 +304,7 @@ object Repeated_content_recommendation_moreday {
 
 
 //      val stat_date = GmeiConfig.getMinusNDate(1)
-      val stat_date = "2019-01-05"
+      val stat_date = "2019-01-06"
 //      val partition_date = stat_date.replace("-","")
 
 
@@ -318,8 +318,8 @@ object Repeated_content_recommendation_moreday {
            |select stat_date,device_id,concat_ws(',',collect_set(distinct cid_id)) as expoure_diary
            |from data_feed_exposure_precise
            |where cid_type = 'diary'
-           |and stat_date >='2018-12-20'
-           |and stat_date <'2019-01-05'
+           |and stat_date >='2018-12-21'
+           |and stat_date <'2019-01-06'
            |group by device_id,stat_date
          """.stripMargin
       ).rdd.map(row=>(row(0).toString,row(1).toString,row(2).toString)).map(row=>(row._2,row._3)).groupByKey()