pyspark.streaming.DStream.checkpoint

DStream。 检查点 ( 时间间隔:int )→pyspark.streaming.dstream.DStream(T]

使这个DStream周期性的检查点的抽样

参数

时间间隔 int

时间以秒为单位,每一段时间后,生成的抽样将检查点

以前的

pyspark.streaming.DStream.cache

下一个

pyspark.streaming.DStream.cogroup