org.apache.spark.scheduler

Class AsyncEventQueue

Object

org.apache.spark.scheduler.AsyncEventQueue

All Implemented Interfaces:

Logging

public class AsyncEventQueue
extends Object
implements Logging

An asynchronous queue for events. All events posted to this queue will be delivered to the child listeners in a separate thread.

Delivery will only begin when the start() method is called. The stop() method should be called when no more events need to be delivered.

Constructor Summary

Constructors

Constructor and Description
AsyncEventQueue(String name, SparkConf conf, org.apache.spark.scheduler.LiveListenerBusMetrics metrics, org.apache.spark.scheduler.LiveListenerBus bus)

Method Summary

Modifier and Type	Method and Description
static void	addListener(L listener)
void	doPostEvent(org.apache.spark.scheduler.SparkListenerInterface listener, SparkListenerEvent event)
String	name()
static Object	POISON_PILL()
void	post(SparkListenerEvent event)
static void	postToAll(E event)
static void	removeListener(L listener)
void	removeListenerOnError(org.apache.spark.scheduler.SparkListenerInterface listener)
boolean	waitUntilEmpty(long deadline) For testing only.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

Constructor Detail

AsyncEventQueue

public AsyncEventQueue(String name,
                       SparkConf conf,
                       org.apache.spark.scheduler.LiveListenerBusMetrics metrics,
                       org.apache.spark.scheduler.LiveListenerBus bus)

Method Detail

POISON_PILL

public static Object POISON_PILL()

addListener

public static final void addListener(L listener)

removeListener

public static final void removeListener(L listener)

postToAll

public static void postToAll(E event)

name

public String name()

post

public void post(SparkListenerEvent event)

waitUntilEmpty

public boolean waitUntilEmpty(long deadline)

For testing only. Wait until there are no more events in the queue.

Parameters:

deadline - (undocumented)

Returns:

true if the queue is empty.

removeListenerOnError

public void removeListenerOnError(org.apache.spark.scheduler.SparkListenerInterface listener)

doPostEvent

public void doPostEvent(org.apache.spark.scheduler.SparkListenerInterface listener,
                        SparkListenerEvent event)