pyspark.streaming.StreamingContext.checkpoint

StreamingContext。 检查点 ( 目录:str )→没有

设置上下文来周期性的检查点DStream操作掌握容错。图将每批间隔检查点。

参数

目录 str

检查点HDFS-compatible目录数据将被可靠地存储

以前的

pyspark.streaming.StreamingContext.awaitTerminationOrTimeout

下一个

pyspark.streaming.StreamingContext.getActive