SparkStreaming的單詞計數案例

import org.apache.spark.streaming.dstream.ReceiverInputDStream import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.{SparkConf, SparkContext} /** * 須要用到nc -lk 9999
相關文章
相關標籤/搜索