星火流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"); 

抱歉，如果我错了..