千家信息网

SparkStreamingContext

发表于:2025-02-02 作者:千家信息网编辑
千家信息网最后更新 2025年02月02日,创建SparkStreamingContext1)val conf=new SparkConf().setMaster("local[2]").setAppName("wordcount")val s
千家信息网最后更新 2025年02月02日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