repair

cf30ea19 · 王志伟 · 2d747e5a · cf30ea19
Commit cf30ea19 authored Nov 14, 2018 by 王志伟
Show whitespace changes
Inline Side-by-side

Showing with 5 additions and 2 deletions

Search_keywords_count.scala ...ededa/src/main/scala/com/gmei/Search_keywords_count.scala +5 -2

No files found.
--- a/eda/feededa/src/main/scala/com/gmei/Search_keywords_count.scala
+++ b/eda/feededa/src/main/scala/com/gmei/Search_keywords_count.scala
@@ -54,8 +54,11 @@ object Search_keywords_count {
         """.stripMargin
      )
      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,true)
+      val temp=get_result.take(10)
+      for (i <- 0 to 9) {
+        println(temp(i))
+      }

    }