您一次只能拥有一个SparkContext,并且由于StreamingContext中包含一个SparkContext,因此在同一代码中不能有单独的Streaming和Spark
Context。您可以做的是在SparkContext的基础上构建一个StreamingContext,这样,如果您确实需要,就可以访问两者。
使用此构造函数
JavaStreamingContext(sparkContext: JavaSparkContext, batchDuration:Duration)
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)