Spark Streaming的wordcount案例

之前測試的一些spark案例都是採用離線處理,spark streaming的流處理一樣可以運行經典的wordcount。 基本環境: spark-2.0.0 scala-2.11.0 IDEA-15.0.6 創建項目,貼上代碼: package org.iie import org.apache.log4j.{Level,Logger} import org.apache.spark.stor
相關文章
相關標籤/搜索