StreamingContext.
addStreamingListener
Add a [[org.apache.spark.streaming.scheduler.StreamingListener]] object for receiving system events related to streaming.
previous
pyspark.streaming.DStream
next
pyspark.streaming.StreamingContext.awaitTermination