pyspark.streaming.StreamingContext.awaitTermination

StreamingContext.awaitTermination(timeout: Optional[int] = None) → None

Wait for the execution to stop.

Parameters

timeoutint, optional

time to wait in seconds

previous

pyspark.streaming.StreamingContext.addStreamingListener

next

pyspark.streaming.StreamingContext.awaitTerminationOrTimeout