SparkStreaming实现HDFS的wordCount(java版)_"javadstream<string> lines = jssc.textfilestream(\-CSDN博客

网站介绍:文章浏览阅读2.3k次。利用sparkstreaming实现hdfs文件系统中的某个目录下的wordcount代码如下:package sparkTestJava;import java.util.Arrays;import org.apache.spark.SparkConf;import org.apache.spark.api.java.function.FlatMapFunction;impo_"javadstream lines = jssc.textfilestream(\"datas\");"