pyspark.streaming.StreamingContext.addStreamingListener

StreamingContext.addStreamingListener(streamingListener: pyspark.streaming.listener.StreamingListener) → None

Add a [[org.apache.spark.streaming.scheduler.StreamingListener]] object for receiving system events related to streaming.

pyspark.streaming.DStream pyspark.streaming.StreamingContext.awaitTermination