StreamingContext。
檢查點
設置上下文來周期性的檢查點DStream操作掌握容錯。圖將每批間隔檢查點。
檢查點HDFS-compatible目錄數據將被可靠地存儲
以前的
pyspark.streaming.StreamingContext.awaitTerminationOrTimeout
下一個
pyspark.streaming.StreamingContext.getActive