网站介绍:文章浏览阅读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\");"
- 链接地址:https://blog.csdn.net/YQlakers/article/details/72867799
- 链接标题:SparkStreaming实现HDFS的wordCount(java版)_"javadstream<string> lines = jssc.textfilestream(\-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:2969
- 网站标签:"javadstream<string> lines = jssc.textfilestream(\"datas\");"