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

Class SuspendedTaskImpl

java.lang.Object

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

All Implemented Interfaces:

SuspendedTask, Message, Identifiable

public final class SuspendedTaskImpl
extends Object
implements SuspendedTask

Implementation of SuspendedTask.

Constructor Summary

Constructors

Constructor and Description
SuspendedTaskImpl(ActiveContext context, byte[] message, String id)

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	get() Message payload.
ActiveContext	getActiveContext()
String	getId() Returns an identifier of this object.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SuspendedTaskImpl

public SuspendedTaskImpl(ActiveContext context,
                 byte[] message,
                 String id)

Method Detail

getActiveContext

public ActiveContext getActiveContext()

Specified by:

getActiveContext in interface SuspendedTask

Returns:

the context the task ran on. This context is now available to run another task or to spwan new child context

get

public byte[] get()

Description copied from interface: Message

Message payload.

Specified by:

get in interface Message

Returns:

message payload

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

toString

public String toString()

Overrides:

toString in class Object