com.twitter.heron.scheduler.yarn

Class HeronMasterDriver.HeronCompletedTaskHandler

java.lang.Object

com.twitter.heron.scheduler.yarn.HeronMasterDriver.HeronCompletedTaskHandler

All Implemented Interfaces:

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

Enclosing class:

HeronMasterDriver

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

Tasks will be closed when on a restart request from user. The intent is to retain the container and just restart the executor process. Hence do-nothing when a task completes.

Constructor Summary

Constructors

Constructor and Description
HeronCompletedTaskHandler()

Method Summary

Modifier and Type	Method and Description
void	onNext(org.apache.reef.driver.task.CompletedTask completedTask)

Methods inherited from class java.lang.Object

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

Constructor Detail

HeronCompletedTaskHandler

public HeronCompletedTaskHandler()

Method Detail

onNext

public void onNext(org.apache.reef.driver.task.CompletedTask completedTask)

Specified by:

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