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

>>阅读原文<<