org.apache.spark.scheduler

Class LiveListenerBus

Object

org.apache.spark.util.AsynchronousListenerBus<SparkListener,SparkListenerEvent>

org.apache.spark.scheduler.LiveListenerBus

All Implemented Interfaces:

Logging, SparkListenerBus, ListenerBus<SparkListener,SparkListenerEvent>

public class LiveListenerBus
extends AsynchronousListenerBus<SparkListener,SparkListenerEvent>
implements SparkListenerBus

Asynchronously passes SparkListenerEvents to registered SparkListeners.

Until start() is called, all posted events are only buffered. Only after this listener bus has started will events be actually propagated to all attached listeners. This listener bus is stopped when it receives a SparkListenerShutdown event, which is posted using stop().

Constructor Summary

Constructors

Constructor and Description
LiveListenerBus()

Method Summary

Methods

Modifier and Type	Method and Description
void	onDropEvent(SparkListenerEvent event) If the event queue exceeds its capacity, the new events will be dropped.

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.scheduler.SparkListenerBus

onPostEvent

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

Constructor Detail

LiveListenerBus

public LiveListenerBus()

Method Detail

onDropEvent

public void onDropEvent(SparkListenerEvent 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<SparkListener,SparkListenerEvent>