org.apache.spark.scheduler

Class DAGSchedulerEventProcessLoop

Object

org.apache.spark.util.EventLoop<DAGSchedulerEvent>

org.apache.spark.scheduler.DAGSchedulerEventProcessLoop

All Implemented Interfaces:

Logging

public class DAGSchedulerEventProcessLoop
extends EventLoop<DAGSchedulerEvent>
implements Logging

Constructor Summary

Constructors

Constructor and Description
DAGSchedulerEventProcessLoop(DAGScheduler dagScheduler)

Method Summary

Methods

Modifier and Type	Method and Description
void	onError(Throwable e) Invoked if onReceive throws any non fatal error.
void	onReceive(DAGSchedulerEvent event) The main event loop of the DAG scheduler.
void	onStop() Invoked when stop() is called and the event thread exits.

Methods inherited from class org.apache.spark.util.EventLoop

isActive, post, start, stop

Methods inherited from class Object

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

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

DAGSchedulerEventProcessLoop

public DAGSchedulerEventProcessLoop(DAGScheduler dagScheduler)

Method Detail

onReceive

public void onReceive(DAGSchedulerEvent event)

The main event loop of the DAG scheduler.

onError

public void onError(Throwable e)

Description copied from class: EventLoop

Invoked if onReceive throws any non fatal error. Any non fatal error thrown from onError will be ignored.

onStop

public void onStop()

Description copied from class: EventLoop

Invoked when stop() is called and the event thread exits.