org.apache.spark.scheduler

Interface SparkListenerBus

All Superinterfaces:

ListenerBus<SparkListener,SparkListenerEvent>, Logging

All Known Implementing Classes:

LiveListenerBus, ReplayListenerBus

public interface SparkListenerBus
extends ListenerBus<SparkListener,SparkListenerEvent>

A SparkListenerEvent bus that relays SparkListenerEvents to its listeners

Method Summary

Methods

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

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

addListener, listeners, postToAll

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

onPostEvent

void onPostEvent(SparkListener 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.

Specified by:

onPostEvent in interface ListenerBus<SparkListener,SparkListenerEvent>