spark-streaming實踐代碼

實踐1:wordcount 1.1本地跑wordcount代碼(無狀態): package com.badou.streaming import org.apache.spark.SparkConf import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.storage.Stora
相關文章
相關標籤/搜索