StreamingContext。
addStreamingListener
添加一個[[org.apache.spark.streaming.scheduler。StreamingListener]]對象接收係統事件流有關。
以前的
pyspark.streaming.DStream
下一個
pyspark.streaming.StreamingContext.awaitTermination