Skip to content

F
ffm-baseline
Commit 2d747e5a authored by 王志伟's avatar 王志伟
Browse files
Options

repair bug

parent 49529100
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
eda/feededa/src/main/scala/com/gmei/Search_keywords_count.scala
View file @ 2d747e5a
...@@ -53,7 +53,7 @@ object Search_keywords_count { ...@@ -53,7 +53,7 @@ object Search_keywords_count {
|and partition_date ='${partition_date}' |and partition_date ='${partition_date}'
""".stripMargin """.stripMargin
) )
val get_result =search_keywords.rdd.flatMap(x=>x).map((_, 1)).reduceByKey(_ + _) val get_result =search_keywords.rdd.map((_, 1)).reduceByKey(_ + _)
.sortBy(_._2,false).repartition(1).saveAsTextFile("/srv/apps/ffm-baseline/eda/feededa/search_keywords.txt") .sortBy(_._2,false).repartition(1).saveAsTextFile("/srv/apps/ffm-baseline/eda/feededa/search_keywords.txt")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment