统计like项目

eea1fa00 · 王志伟 · 61a9e180 · eea1fa00
Commit eea1fa00 authored Mar 26, 2019 by 王志伟
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

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

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/temp_analysis.scala
+++ b/eda/feededa/src/main/scala/com/gmei/temp_analysis.scala
@@ -593,8 +593,8 @@ object alpha_ctr {
      )
      expoure_count_recommend.rdd.map(row =>{
        val s = row.getAs[List[String]]("exposure_cards")
-        println(s.length)
-      })
+        (stat_date,s.length)
+      }).reduceByKey((x,y) => x + y).toDF("stat_date","count").show()