org.apache.reef.driver.task

Interface RunningTask

All Superinterfaces:

AutoCloseable, Identifiable

All Known Implementing Classes:

RunningTaskImpl

public interface RunningTask
extends Identifiable, AutoCloseable

Represents a running Task.

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()
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.

Methods inherited from interface org.apache.reef.io.naming.Identifiable

getId

Method Detail

getActiveContext

ActiveContext getActiveContext()

Returns:

the context the task is running on.

send

void send(byte[] message)

Sends the message to the running task.

Parameters:

message - to be sent to the running task

suspend

void suspend(byte[] message)

Signal the task to suspend.

Parameters:

message - a message that is sent to the Task.

suspend

void suspend()

Signal the task to suspend.

close

void close(byte[] message)

Signal the task to shut down.

Parameters:

message - a message that is sent to the Task.

close

void close()

Signal the task to shut down.

Specified by:

close in interface AutoCloseable

getTaskRepresenter

TaskRepresenter getTaskRepresenter()

Gets the representer of task.

Returns:

the representer of task