pyspark.streaming.StreamingContext.awaitTerminationOrTimeout

StreamingContext。 awaitTerminationOrTimeout ( 超時:int )→沒有

等待執行停止。返回真正的如果停止;或執行期間把報告錯誤;或假如果從方法返回之前等待的時間。

參數

超時 int

時間等待秒

以前的

pyspark.streaming.StreamingContext.awaitTermination

下一個

pyspark.streaming.StreamingContext.checkpoint