org.apache.reef.examples.scheduler.driver

Class SchedulerDriver.ActiveContextHandler

java.lang.Object

org.apache.reef.examples.scheduler.driver.SchedulerDriver.ActiveContextHandler

All Implemented Interfaces:

EventHandler<ActiveContext>

Enclosing class:

SchedulerDriver

public final class SchedulerDriver.ActiveContextHandler
extends Object
implements EventHandler<ActiveContext>

Now it is ready to schedule tasks. But if the queue is empty, wait until commands coming up. If there is no pending task, having more than 1 evaluators must be redundant. It may happen, for example, when tasks are canceled during allocation. In these cases, the new evaluator may be abandoned.

Constructor Summary

Constructors

Constructor and Description
ActiveContextHandler()

Method Summary

Modifier and Type	Method and Description
void	onNext(ActiveContext context) Handles an event.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveContextHandler

public ActiveContextHandler()

Method Detail

onNext

public void onNext(ActiveContext context)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<ActiveContext>

Parameters:

context - an event