com.twitter.heron.scheduler.yarn

Class HeronMasterDriver.HeronWorkerStartHandler

java.lang.Object

com.twitter.heron.scheduler.yarn.HeronMasterDriver.HeronWorkerStartHandler

All Implemented Interfaces:

org.apache.reef.wake.EventHandler<org.apache.reef.driver.task.RunningTask>

Enclosing class:

HeronMasterDriver

public final class HeronMasterDriver.HeronWorkerStartHandler
extends java.lang.Object
implements org.apache.reef.wake.EventHandler<org.apache.reef.driver.task.RunningTask>

This class manages active tasks. The task handlers provided by REEF will be memorized to be used later for operations like topology restart. Restarting a task does not require new container request.

Constructor Summary

Constructors

Constructor and Description
HeronWorkerStartHandler()

Method Summary

Modifier and Type	Method and Description
void	onNext(org.apache.reef.driver.task.RunningTask runningTask)

Methods inherited from class java.lang.Object

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

Constructor Detail

HeronWorkerStartHandler

public HeronWorkerStartHandler()

Method Detail

onNext

public void onNext(org.apache.reef.driver.task.RunningTask runningTask)

Specified by:

onNext in interface org.apache.reef.wake.EventHandler<org.apache.reef.driver.task.RunningTask>