Scalable Stream Processing - Spark Streaming and FlinkStreamingContext(conf, Seconds(1)) ▶ It can also be created from an existing SparkContext object. val sc = ... // existing SparkContext val ssc = new StreamingContext(sc, Seconds(1)) 10 / 79 StreamingContext StreamingContext(conf, Seconds(1)) ▶ It can also be created from an existing SparkContext object. val sc = ... // existing SparkContext val ssc = new StreamingContext(sc, Seconds(1)) 10 / 79 Operations on0 码力 | 113 页 | 1.22 MB | 1 年前3
共 1 条
- 1