Output Operations on DStreams

print():打印DStream中的前10行數據oop

saveAsTextFiles(prefix, [suffix]):保存成文本文件到prefix指定的目錄下,後綴爲suffixhadoop

saveAsObjectFiles(prefix, [suffix]) :保存DStream數據爲 SequenceFiles 或者 serialized Java objectsobject

saveAsHadoopFiles(prefix, [suffix]) :保存文件到hadoop上foreach

foreachRDD(func):遍歷DStream中的RDD遍歷

相關文章
相關標籤/搜索