第1关：套接字流实现黑名单过滤
代码：
import org.apache.spark.SparkConf
import org.apache.spark.streaming.StreamingContext
import org.apache.spark.streaming.Seconds文章来源：https://www.toymoban.com/news/detail-452394.html
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")
文章来源地址https://www.toymoban.com/news/detail-452394.html
到了这里，关于Spark Streaming（头歌）的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
