pyspark.streaming.StreamingContext.checkpoint

StreamingContext。 檢查點 ( 目錄:str )→沒有

設置上下文來周期性的檢查點DStream操作掌握容錯。圖將每批間隔檢查點。

參數
目錄 str

檢查點HDFS-compatible目錄數據將被可靠地存儲