使用 RDD 的 Spark 流上下文

Question

rdd.context() 是否提供与 ssc.sparkContext() 相同的上下文？

ssc = new JavaStreamingContext(sparkConf, new Duration(5000));

并且rdd是从ssc生成的。

Answer 1

是 rdd.Context() returns 创建此 RDD 的 SparkContext。