千家信息网

SparkStreamingContext

发表于:2024-11-14 作者:千家信息网编辑
千家信息网最后更新 2024年11月14日,创建SparkStreamingContext1)val conf=new SparkConf().setMaster("local[2]").setAppName("wordcount")val s
千家信息网最后更新 2024年11月14日SparkStreamingContext
  1. 创建SparkStreamingContext

    1)val conf=new SparkConf().setMaster("local[2]").setAppName("wordcount")

val streamContext=new StreamingContext(conf,Seconds(5))

2)val sps=new StreamingContext(new SparkContext(conf),Seconds(5))

//如果关闭的时候只想关闭StreamingContext不想关闭SparkContext则

sps.stop(false)

0