统计like项目

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

Showing with 3 additions and 1 deletion

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

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
@@ -594,7 +594,9 @@ object alpha_ctr {
      expoure_count_recommend.rdd.map(row =>{
        val s = row.getAs[List[String]]("exposure_cards")
        (stat_date,s.length)
-      }).reduceByKey((x,y) => x + y).toDF("stat_date","count").show()
+      })
+        //.reduceByKey((x,y) => x + y)
+        .toDF("stat_date","count").show()