星火流saveAsTextFiles功能 [英] Spark streaming saveAsTextFiles function

问题描述

如何申请 saveAsTextFiles（preFIX，[后缀]）结果
我有这样的：

how to apply saveAsTextFiles(prefix,[suffix])
I have this :

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

当我写hashTags.print（）的工作，我在终端接收数据时，我去了做的是保存在与Java的一个文本文件中这一数据。

When i write hashTags.print() its work and i receive data in the terminal , what i went to do is save this data in a text file with java .

推荐答案

请尝试以下code：

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

这篇关于星火流saveAsTextFiles功能的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！