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
相关文章
相关标签/搜索