org.apache.reef.runtime.common.evaluator.task

Class TaskRuntime

java.lang.Object

org.apache.reef.runtime.common.evaluator.task.TaskRuntime

All Implemented Interfaces:

Runnable

public final class TaskRuntime
extends Object
implements Runnable

The execution environment for a Task.

Method Summary

Methods

Modifier and Type	Method and Description
void	close(byte[] message) Close the Task.
void	deliver(byte[] message) Deliver a message to the Task.
String	getId()
ReefServiceProtos.TaskStatusProto	getStatusProto() Called by heartbeat manager
String	getTaskId()
boolean	hasEnded()
void	initialize() This method needs to be called before a Task can be run().
void	run() Run the task: Fire TaskStart, call Task.call(), fire TaskStop.
void	suspend(byte[] message) Suspend the Task.

Methods inherited from class java.lang.Object

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

Method Detail

initialize

public void initialize()

This method needs to be called before a Task can be run(). It informs the Driver that the Task is initializing.

run

public void run()

Run the task: Fire TaskStart, call Task.call(), fire TaskStop.

Specified by:

run in interface Runnable

getStatusProto

public ReefServiceProtos.TaskStatusProto getStatusProto()

Called by heartbeat manager

Returns:

current TaskStatusProto

hasEnded

public boolean hasEnded()

Returns:

true, if the Task is no longer running, either because it is crashed or exited cleanly

getTaskId

public String getTaskId()

Returns:

the ID of the task.

getId

public String getId()

close

public final void close(byte[] message)

Close the Task. This calls the configured close handler.

Parameters:

message - the optional message for the close handler or null if there none.

suspend

public void suspend(byte[] message)

Suspend the Task. This calls the configured suspend handler.

Parameters:

message - the optional message for the suspend handler or null if there none.

deliver

public void deliver(byte[] message)

Deliver a message to the Task. This calls into the user supplied message handler.

Parameters:

message - the message to be delivered.