Uses of Interface
org.apache.reef.driver.task.RunningTask

Packages that use RunningTask

Package	Description
org.apache.reef.client	Client APIs for REEF.
org.apache.reef.io.network.group.api.driver	Elastic Group Communications Driver-side API Interfaces.
org.apache.reef.io.network.group.impl.driver	This package contains the implementation of the driver side of the Group Communication Service using the tree/flat topology.
org.apache.reef.io.watcher	Watcher subscribes events and writes them to the destination using a certain EventStream.
org.apache.reef.io.watcher.util	Utility classes for Watcher.
org.apache.reef.javabridge	The Java-side of the CLR/Java bridge.
org.apache.reef.javabridge.generic	Generic java bridge driver/client.
org.apache.reef.runtime.common.driver.defaults	Default implementations for the optional driver-side event handlers.
org.apache.reef.runtime.common.driver.evaluator	Driver-Side representations of Evaluators.
org.apache.reef.runtime.common.driver.task	Driver-Side representations of tasks.
org.apache.reef.tests.fail.driver	Tests for Driver-side failures.
org.apache.reef.tests.messaging.task	Test message exchange between the Task and the Driver.
org.apache.reef.tests.watcher	Test reef.io.watcher.
org.apache.reef.webserver	HTTP Server component to implement a REST API for the Driver or Evaluators.

Uses of RunningTask in org.apache.reef.client

Fields in org.apache.reef.client with type parameters of type RunningTask

Modifier and Type	Field and Description
static OptionalImpl<EventHandler<RunningTask>>	DriverRestartConfiguration.ON_DRIVER_RESTART_TASK_RUNNING Event handler for running tasks in previous evaluator, when driver restarted.
static OptionalImpl<EventHandler<RunningTask>>	DriverServiceConfiguration.ON_TASK_RUNNING Event handler for running tasks.
static OptionalImpl<EventHandler<RunningTask>>	DriverConfiguration.ON_TASK_RUNNING Event handler for running tasks.

Uses of RunningTask in org.apache.reef.io.network.group.api.driver

Methods in org.apache.reef.io.network.group.api.driver that return types with arguments of type RunningTask

Modifier and Type	Method and Description
EStage<RunningTask>	GroupCommServiceDriver.getGroupCommRunningTaskStage() Not user facing but used the Group Communication Service class.

Uses of RunningTask in org.apache.reef.io.network.group.impl.driver

Methods in org.apache.reef.io.network.group.impl.driver that return types with arguments of type RunningTask

Modifier and Type	Method and Description
EStage<RunningTask>	GroupCommDriverImpl.getGroupCommRunningTaskStage()

Methods in org.apache.reef.io.network.group.impl.driver with parameters of type RunningTask

Modifier and Type	Method and Description
void	TopologyRunningTaskHandler.onNext(RunningTask runningTask)
void	GroupCommService.RunningTaskHandler.onNext(RunningTask runningTask)

Constructor parameters in org.apache.reef.io.network.group.impl.driver with type arguments of type RunningTask

Constructor and Description

CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.

Uses of RunningTask in org.apache.reef.io.watcher

Methods in org.apache.reef.io.watcher with parameters of type RunningTask

Modifier and Type	Method and Description
void	Watcher.TaskRunningHandler.onNext(RunningTask runningTask)

Uses of RunningTask in org.apache.reef.io.watcher.util

Methods in org.apache.reef.io.watcher.util with parameters of type RunningTask

Modifier and Type	Method and Description
static AvroRunningTask	WatcherAvroUtil.toAvroRunningTask(RunningTask runningTask)

Uses of RunningTask in org.apache.reef.javabridge

Constructors in org.apache.reef.javabridge with parameters of type RunningTask

Constructor and Description
RunningTaskBridge(RunningTask runningTask, ActiveContextBridgeFactory factory)

Uses of RunningTask in org.apache.reef.javabridge.generic

Methods in org.apache.reef.javabridge.generic with parameters of type RunningTask

Modifier and Type	Method and Description
void	JobDriver.RunningTaskHandler.onNext(RunningTask task)
void	JobDriver.DriverRestartRunningTaskHandler.onNext(RunningTask task)

Uses of RunningTask in org.apache.reef.runtime.common.driver.defaults

Methods in org.apache.reef.runtime.common.driver.defaults with parameters of type RunningTask

Modifier and Type	Method and Description
void	DefaultTaskRunningHandler.onNext(RunningTask runningTask)
void	DefaultDriverRestartTaskRunningHandler.onNext(RunningTask runningTask)

Uses of RunningTask in org.apache.reef.runtime.common.driver.evaluator

Methods in org.apache.reef.runtime.common.driver.evaluator with parameters of type RunningTask

Modifier and Type	Method and Description
void	EvaluatorMessageDispatcher.onDriverRestartTaskRunning(RunningTask runningTask)
void	EvaluatorMessageDispatcher.onTaskRunning(RunningTask runningTask)

Uses of RunningTask in org.apache.reef.runtime.common.driver.task

Classes in org.apache.reef.runtime.common.driver.task that implement RunningTask

Modifier and Type	Class and Description
class	RunningTaskImpl Implements the RunningTask client interface.

Uses of RunningTask in org.apache.reef.tests.fail.driver

Methods in org.apache.reef.tests.fail.driver with parameters of type RunningTask

Modifier and Type	Method and Description
void	FailDriverDelayedMsg.RunningTaskHandler.onNext(RunningTask task)

Uses of RunningTask in org.apache.reef.tests.messaging.task

Methods in org.apache.reef.tests.messaging.task with parameters of type RunningTask

Modifier and Type	Method and Description
void	TaskMessagingDriver.TaskRunningHandler.onNext(RunningTask task)

Uses of RunningTask in org.apache.reef.tests.watcher

Methods in org.apache.reef.tests.watcher with parameters of type RunningTask

Modifier and Type	Method and Description
void	WatcherTestDriver.TaskRunningHandler.onNext(RunningTask runningTask)

Uses of RunningTask in org.apache.reef.webserver

Methods in org.apache.reef.webserver with parameters of type RunningTask

Modifier and Type	Method and Description
void	ReefEventStateManager.TaskRunningStateHandler.onNext(RunningTask runningTask)
void	ReefEventStateManager.DriverRestartTaskRunningStateHandler.onNext(RunningTask runningTask)