pyspark.streaming.StreamingContext.awaitTerminationOrTimeout

StreamingContext。 awaitTerminationOrTimeout ( 超时:int )→没有

等待执行停止。返回真正的如果停止;或执行期间把报告错误;或假如果从方法返回之前等待的时间。

参数

超时 int

时间等待秒

以前的

pyspark.streaming.StreamingContext.awaitTermination

下一个

pyspark.streaming.StreamingContext.checkpoint