0
def textfile={
val ssc = new StreamingContext(conf, Seconds(10))
val lines = ssc.textFileStream("hdfs://master:9000/streaming/")
val words = lines.flatMap(_.split("\\s"));
val pairs = words.map(word => (word, 1));
val wordCounts = pairs.reduceByKey(_ + _);
wordCounts.print();
ssc.start();
ssc.awaitTermination();
}
に表示されていない結果では、ストリーミングアプリケーションを起動した後StreamingContext.textfilestreamファイルが読み込まれますが、何の結果は、コンソール
埋め込み画像 –