org.apache.spark.streaming.scheduler

Class StreamingListenerBus

Object

org.apache.spark.util.AsynchronousListenerBus<StreamingListener,StreamingListenerEvent>

org.apache.spark.streaming.scheduler.StreamingListenerBus

All Implemented Interfaces:

Logging, ListenerBus<StreamingListener,StreamingListenerEvent>

public class StreamingListenerBus
extends AsynchronousListenerBus<StreamingListener,StreamingListenerEvent>
implements Logging

Asynchronously passes StreamingListenerEvents to registered StreamingListeners.

Constructor Summary

Constructors

Constructor and Description
StreamingListenerBus()

Method Summary

Methods

Modifier and Type	Method and Description
void	onDropEvent(StreamingListenerEvent event) If the event queue exceeds its capacity, the new events will be dropped.
void	onPostEvent(StreamingListener listener, StreamingListenerEvent event) Post an event to the specified listener.

Methods inherited from class org.apache.spark.util.AsynchronousListenerBus

listenerThreadIsAlive, post, start, stop, waitUntilEmpty

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Methods inherited from interface org.apache.spark.util.ListenerBus

addListener, listeners, postToAll

Constructor Detail

StreamingListenerBus

public StreamingListenerBus()

Method Detail

onPostEvent

public void onPostEvent(StreamingListener listener,
               StreamingListenerEvent event)

Description copied from interface: ListenerBus

Post an event to the specified listener. onPostEvent is guaranteed to be called in the same thread.

Specified by:

onPostEvent in interface ListenerBus<StreamingListener,StreamingListenerEvent>

onDropEvent

public void onDropEvent(StreamingListenerEvent event)

Description copied from class: AsynchronousListenerBus

If the event queue exceeds its capacity, the new events will be dropped. The subclasses will be notified with the dropped events.

Note: onDropEvent can be called in any thread.

Specified by:

onDropEvent in class AsynchronousListenerBus<StreamingListener,StreamingListenerEvent>