org.apache.spark.util

Interface ListenerBus<L,E>

All Superinterfaces:

Logging

All Known Subinterfaces:

SparkListenerBus

All Known Implementing Classes:

AsynchronousListenerBus, LiveListenerBus, ReplayListenerBus, StreamingListenerBus

public interface ListenerBus<L,E>
extends Logging

An event bus which posts events to its listeners.

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(L listener) Add a listener to listen events.
java.util.concurrent.CopyOnWriteArrayList<L>	listeners()
void	onPostEvent(L listener, E event) Post an event to the specified listener.
void	postToAll(E event) Post the event to all registered listeners.

Methods inherited from interface org.apache.spark.Logging

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

Method Detail

listeners

java.util.concurrent.CopyOnWriteArrayList<L> listeners()

addListener

void addListener(L listener)

Add a listener to listen events. This method is thread-safe and can be called in any thread.

postToAll

void postToAll(E event)

Post the event to all registered listeners. The postToAll caller should guarantee calling postToAll in the same thread for all events.

onPostEvent

void onPostEvent(L listener,
               E event)

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