大数据 scala Spark Streaming（头歌）

第1关：套接字流实现黑名单过滤

 代码：

import org.apache.spark.SparkConf import org.apache.spark.streaming.StreamingContext import org.apache.spark.streaming.Seconds

object TransformBlackList {

  def main(args: Array[String]): Unit = {

    /********** Begin **********/  //初始化     val sparkConf = new SparkConf().setAppName("TransformBlackList").setMaster("local[2]")     //创建StreamingContext，设置每五秒秒刷新一次     val ssc = new StreamingContext(sparkConf, Seconds(5))     ssc.sparkContext.setLogLevel("error")

参考链接

 您阅读本篇文章共花了：