pyspark.streaming.StreamingContext.awaitTermination#

StreamingContext.awaitTermination(timeout=None)[source]#

Wait for the execution to stop.

Parameters

timeoutint, optional: time to wait in seconds