pyspark.streaming.StreamingContext.awaitTerminationOrTimeout

StreamingContext. awaitTerminationOrTimeout ( timeout : int ) → None

等待执行停止。如果执行停止则返回 true ；或者在执行过程中抛出报告的错误；或者如果在方法返回之前等待时间已过，则返回 false 。

Parameters

timeout int

等待时间（秒）

上一篇

pyspark.streaming.StreamingContext.awaitTermination

下一页

pyspark.streaming.StreamingContext.checkpoint