pyspark.streaming.StreamingContext.awaitTerminationOrTimeout

StreamingContext.awaitTerminationOrTimeout(timeout)

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

pyspark.streaming.StreamingContext.awaitTermination pyspark.streaming.StreamingContext.checkpoint