public interface SparkListenerBus extends Logging
Modifier and Type | Method and Description |
---|---|
void |
addListener(SparkListener listener) |
void |
foreachListener(scala.Function1<SparkListener,scala.runtime.BoxedUnit> f)
Apply the given function to all attached listeners, catching and logging any exception.
|
void |
postToAll(SparkListenerEvent event)
Post an event to all attached listeners.
|
scala.collection.mutable.ArrayBuffer<SparkListener> |
sparkListeners() |
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
scala.collection.mutable.ArrayBuffer<SparkListener> sparkListeners()
void addListener(SparkListener listener)
void postToAll(SparkListenerEvent event)
void foreachListener(scala.Function1<SparkListener,scala.runtime.BoxedUnit> f)