SparkStreaming的单词计数案例

import org.apache.spark.streaming.dstream.ReceiverInputDStream import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.{SparkConf, SparkContext} /** * 须要用到nc -lk 9999
相关文章
相关标签/搜索