星火流saveAsTextFiles功能

Question

如何申請saveAsTextFiles(prefix,[suffix])
我有這樣的：

 JavaDStream<String> hashTags = statuses 
      .filter(new Function<String, Boolean>() { 
       public Boolean call(String word) { 
        return word.contains("#"); 
       } 
      }); 

當我寫hashTags.print（）的工作，我在終端接收數據時，我去了要做的就是保存這個用java編寫的文本文件中的數據。

Answer 1

不知道你的問題是什麼...但試試這個：

1. 從原始數據源

   RDD2 = rdd1.filter（...）

2. RDD2創建RDD .saveAsTextFile（...）

Answer 2

試試下面的代碼：

hashTags.dstream().saveAsTextFiles("myoutput","txt"); 

Answer 3

saveAsTextFile函數只能由rdd spark實現。涉及到我們的代碼會是這樣的：

JavaDStream<String> hashTags = statuses 
.filter(new Function<String, Boolean>() { 
     public Boolean call(String word) { 
     return word.contains("#"); 
     } 
    }); 
hashTags.saveAsTextFile("location.txt"); 

抱歉，如果我錯了..