org.apache.reef.runtime.common.driver.task

Class RunningTaskImpl

java.lang.Object

org.apache.reef.runtime.common.driver.task.RunningTaskImpl

All Implemented Interfaces:

AutoCloseable, RunningTask, Identifiable

public final class RunningTaskImpl
extends Object
implements RunningTask

Implements the RunningTask client interface. It is mainly a helper class that will package up various client method calls into protocol buffers and pass them to its respective EvaluatorManager to deliver to the EvaluatorRuntime.

Constructor Summary

Constructors

Constructor and Description
RunningTaskImpl(EvaluatorManager evaluatorManager, String taskId, EvaluatorContext evaluatorContext, TaskRepresenter taskRepresenter)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Signal the task to shut down.
void	close(byte[] message) Signal the task to shut down.
ActiveContext	getActiveContext()
String	getId() Returns an identifier of this object.
TaskRepresenter	getTaskRepresenter() Gets the representer of task.
void	send(byte[] message) Sends the message to the running task.
void	suspend() Signal the task to suspend.
void	suspend(byte[] message) Signal the task to suspend.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RunningTaskImpl

public RunningTaskImpl(EvaluatorManager evaluatorManager,
               String taskId,
               EvaluatorContext evaluatorContext,
               TaskRepresenter taskRepresenter)

Method Detail

getActiveContext

public ActiveContext getActiveContext()

Specified by:

getActiveContext in interface RunningTask

Returns:

the context the task is running on.

getId

public String getId()

Description copied from interface: Identifiable

Returns an identifier of this object.

Specified by:

getId in interface Identifiable

Returns:

an identifier of this object

send

public void send(byte[] message)

Description copied from interface: RunningTask

Sends the message to the running task.

Specified by:

send in interface RunningTask

Parameters:

message - to be sent to the running task

close

public void close()

Description copied from interface: RunningTask

Signal the task to shut down.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RunningTask

close

public void close(byte[] message)

Description copied from interface: RunningTask

Signal the task to shut down.

Specified by:

close in interface RunningTask

Parameters:

message - a message that is sent to the Task.

suspend

public void suspend(byte[] message)

Description copied from interface: RunningTask

Signal the task to suspend.

Specified by:

suspend in interface RunningTask

Parameters:

message - a message that is sent to the Task.

suspend

public void suspend()

Description copied from interface: RunningTask

Signal the task to suspend.

Specified by:

suspend in interface RunningTask

toString

public String toString()

Overrides:

toString in class Object

getTaskRepresenter

public TaskRepresenter getTaskRepresenter()

Description copied from interface: RunningTask

Gets the representer of task.

Specified by:

getTaskRepresenter in interface RunningTask

Returns:

the representer of task