org.apache.spark.scheduler

Interface SparkListenerBus

All Superinterfaces:

ListenerBus<SparkListenerInterface,SparkListenerEvent>, org.apache.spark.internal.Logging

All Known Implementing Classes:

AsyncEventQueue

public interface SparkListenerBus
extends ListenerBus<SparkListenerInterface,SparkListenerEvent>

A SparkListenerEvent bus that relays SparkListenerEvents to its listeners

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.SparkShellLoggingFilter

Method Summary

Modifier and Type	Method and Description
void	doPostEvent(SparkListenerInterface listener, SparkListenerEvent event) Post an event to the specified listener.

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

addListener, findListenersByClass, getTimer, isIgnorableException, listeners, postToAll, redactEvent, removeAllListeners, removeListener, removeListenerOnError

Methods inherited from interface org.apache.spark.internal.Logging

$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitialize

Method Detail

doPostEvent

void doPostEvent(SparkListenerInterface listener,
                 SparkListenerEvent event)

Description copied from interface: ListenerBus

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

Specified by:

doPostEvent in interface ListenerBus<SparkListenerInterface,SparkListenerEvent>

Parameters:

listener - (undocumented)

event - (undocumented)