pyspark.streaming.DStream.checkpoint

DStream。 檢查點 ( 時間間隔:int )→pyspark.streaming.dstream.DStream(T]

使這個DStream周期性的檢查點的抽樣

參數

時間間隔 int

時間以秒為單位,每一段時間後,生成的抽樣將檢查點

以前的

pyspark.streaming.DStream.cache

下一個

pyspark.streaming.DStream.cogroup