pyspark.streaming.StreamingContext.addStreamingListener

StreamingContext。 addStreamingListener ( streamingListener:pyspark.streaming.listener.StreamingListener )→没有

添加一个[[org.apache.spark.streaming.scheduler。StreamingListener]]对象接收系统事件流有关。

以前的

pyspark.streaming.DStream

下一个

pyspark.streaming.StreamingContext.awaitTermination