统计like项目

8fa2a506 · 王志伟 · c49b874b · 8fa2a506
Commit 8fa2a506 authored Mar 26, 2019 by 王志伟
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 2 deletions

temp_analysis.scala eda/feededa/src/main/scala/com/gmei/temp_analysis.scala +1 -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
@@ -592,9 +592,8 @@ object alpha_ctr {
       """.stripMargin
      ).rdd.map(row => {
        val lenth=row.toSeq.length
-        println(lenth)
        (stat_date,lenth)
-      })
+      }).toDF("stat_date","count").show()
        /*.rdd
        .map(row =>{
        val s = row.getAs[List[String]]("exposure_cards")