org.ow2.proactive.scheduler.rest.data

Class TaskResultImpl

java.lang.Object

org.ow2.proactive.scheduler.rest.data.TaskResultImpl

All Implemented Interfaces:

Serializable, TaskResult

public class TaskResultImpl
extends Object
implements TaskResult

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskResultImpl(TaskId id, TaskResultData d)

Method Summary

Modifier and Type	Method and Description
FlowAction	getAction() If a FlowScript was executed on this task, its result is stored it so that the action can be performed later when processed by the core.
Throwable	getException() Retrieve the exception threw by the task.
Map<String,String>	getMetadata() Get metadata associated with this result.
TaskLogs	getOutput() Return the output of the execution, including stdout and stderr.
Map<String,byte[]>	getPropagatedVariables() Return the content of propagated variables, in byte array format
Map<String,Serializable>	getResultMap() Returns a map of job results
byte[]	getSerializedValue() Get the serialized value of the task.
TaskId	getTaskId() To get the id of the task.
Serializable	getValue() Get the value of the task.
Map<String,Serializable>	getVariables() Returns the deserialized version of the propagated variables
boolean	hadException() To know if an exception has occurred on this task.
boolean	isRaw() Returns true if this result contains raw data (i.e.
void	setMetadata(Map<String,String> metadata)
void	setOutput(TaskLogs taskLogs)
void	setValue(Serializable value)
Serializable	value() Get the value of the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskResultImpl

public TaskResultImpl(TaskId id,
                      TaskResultData d)

Method Detail

getAction

public FlowAction getAction()

Description copied from interface: TaskResult

If a FlowScript was executed on this task, its result is stored it so that the action can be performed later when processed by the core.

Specified by:

getAction in interface TaskResult

Returns:

the Control Flow action embedded in this TaskResult

getException

public Throwable getException()

Description copied from interface: TaskResult

Retrieve the exception threw by the task. If the task didn't throw an exception, null is returned

Specified by:

getException in interface TaskResult

Returns:

the exception threw by the task.

setOutput

public void setOutput(TaskLogs taskLogs)

getOutput

public TaskLogs getOutput()

Description copied from interface: TaskResult

Return the output of the execution, including stdout and stderr.

Specified by:

getOutput in interface TaskResult

Returns:

the output of the execution, including stdout and stderr.

getPropagatedVariables

public Map<String,byte[]> getPropagatedVariables()

Description copied from interface: TaskResult

Return the content of propagated variables, in byte array format

Specified by:

getPropagatedVariables in interface TaskResult

Returns:

a map of byte arrays

getVariables

public Map<String,Serializable> getVariables()
                                      throws IOException,
                                             ClassNotFoundException

Description copied from interface: TaskResult

Returns the deserialized version of the propagated variables

Specified by:

getVariables in interface TaskResult

Returns:

a map of variables

Throws:

IOException

ClassNotFoundException

isRaw

public boolean isRaw()

Description copied from interface: TaskResult

Returns true if this result contains raw data (i.e. a byte array) instead of an object

Specified by:

isRaw in interface TaskResult

Returns:

result object type

getResultMap

public Map<String,Serializable> getResultMap()

Description copied from interface: TaskResult

Returns a map of job results

Specified by:

getResultMap in interface TaskResult

Returns:

merged map of job results

getSerializedValue

public byte[] getSerializedValue()

Description copied from interface: TaskResult

Get the serialized value of the task.

Specified by:

getSerializedValue in interface TaskResult

Returns:

the value of the task, null if an exception occurred.

getMetadata

public Map<String,String> getMetadata()

Description copied from interface: TaskResult

Get metadata associated with this result. Metadata let the task add additional information bound to the result. It is the responsibility of the business-code to define the metadata semantics. For example, if the result contains binary data, the metadata map could contain the binary content type, or the name of the file if the result needs to be written on disk.

Specified by:

getMetadata in interface TaskResult

Returns:

a map of metadata

setMetadata

public void setMetadata(Map<String,String> metadata)

getTaskId

public TaskId getTaskId()

Description copied from interface: TaskResult

To get the id of the task.

Specified by:

getTaskId in interface TaskResult

Returns:

the id of the task.

hadException

public boolean hadException()

Description copied from interface: TaskResult

To know if an exception has occurred on this task.

Specified by:

hadException in interface TaskResult

Returns:

true if an exception occurred, false if not.

setValue

public void setValue(Serializable value)

value

public Serializable value()
                   throws Throwable

Description copied from interface: TaskResult

Get the value of the task. Throw the exception if the task generate

Specified by:

value in interface TaskResult

Returns:

the value of the task.

Throws:

Throwable - If the value has generate an exception.

getValue

public Serializable getValue()
                      throws Throwable

Description copied from interface: TaskResult

Get the value of the task. Returns null if an exception occurred during the task execution

Specified by:

getValue in interface TaskResult

Returns:

the value of the task.

Throws:

Throwable