pyspark.streaming.StreamingContext.awaitTerminationOrTimeout¶
-
StreamingContext.awaitTerminationOrTimeout(timeout: int) → None¶ Wait for the execution to stop. Return true if it’s stopped; or throw the reported error during the execution; or false if the waiting time elapsed before returning from the method.
- Parameters
- timeoutint
time to wait in seconds