org.cripac.isee.vpe.ctrl

Class TaskData

java.lang.Object

org.cripac.isee.vpe.ctrl.TaskData

All Implemented Interfaces:

Serializable, Cloneable

public class TaskData
extends Object
implements Serializable, Cloneable

The TaskData class contains a global execution plan and the execution result of the predecessor node.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskData.ExecutionPlan The ExecutionPlan class represents a directed acyclic graph of the execution flows of modules.

Field Summary

Fields

Modifier and Type	Field and Description
Map<Stream.Port,TaskData.ExecutionPlan.Node.Port>	destPorts Current nodes to execute.
TaskData.ExecutionPlan	executionPlan Global execution plan.
DataType	outputType
Serializable	predecessorRes Result of the predecessor.
private static long	serialVersionUID

Constructor Summary

Constructors

Constructor and Description
TaskData(Collection<TaskData.ExecutionPlan.Node.Port> destPorts, TaskData.ExecutionPlan executionPlan) Create a task with an execution plan with no predecessor result.
TaskData(Collection<TaskData.ExecutionPlan.Node.Port> destPorts, TaskData.ExecutionPlan executionPlan, Serializable predecessorRes) Create a task with an execution plan with predecessor result.
TaskData(TaskData.ExecutionPlan.Node.Port destPort, TaskData.ExecutionPlan executionPlan) Create a task with an execution plan with predecessor result.
TaskData(TaskData.ExecutionPlan.Node.Port destPort, TaskData.ExecutionPlan executionPlan, Serializable predecessorRes) Create a task with an execution plan with predecessor result.

Method Summary

Modifier and Type	Method and Description
TaskData.ExecutionPlan.Node	getDestNode(List<Stream.Port> possiblePorts) Get the destination node which contains the given ports.
TaskData.ExecutionPlan.Node	getDestNode(Stream.Port port) Get the destination node which contains the given port.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

destPorts

public final Map<Stream.Port,TaskData.ExecutionPlan.Node.Port> destPorts

Current nodes to execute.

executionPlan

public final TaskData.ExecutionPlan executionPlan

Global execution plan.

outputType

public final DataType outputType

predecessorRes

public final Serializable predecessorRes

Result of the predecessor.

Constructor Detail

TaskData

public TaskData(@Nonnull
                Collection<TaskData.ExecutionPlan.Node.Port> destPorts,
                @Nonnull
                TaskData.ExecutionPlan executionPlan)

Create a task with an execution plan with no predecessor result.

Parameters:

destPorts - Destination ports of this TaskData.

executionPlan - A global execution plan.

TaskData

public TaskData(@Nonnull
                TaskData.ExecutionPlan.Node.Port destPort,
                @Nonnull
                TaskData.ExecutionPlan executionPlan)

Create a task with an execution plan with predecessor result.

Parameters:

destPort - Destination port of this TaskData.

executionPlan - A global execution plan.

TaskData

public TaskData(@Nonnull
                TaskData.ExecutionPlan.Node.Port destPort,
                @Nonnull
                TaskData.ExecutionPlan executionPlan,
                @Nullable
                Serializable predecessorRes)

Create a task with an execution plan with predecessor result.

Parameters:

destPort - Destination port of this TaskData.

executionPlan - A global execution plan.

predecessorRes - Result of the predecessor node, which is a serializable object.

TaskData

public TaskData(@Nonnull
                Collection<TaskData.ExecutionPlan.Node.Port> destPorts,
                @Nonnull
                TaskData.ExecutionPlan executionPlan,
                @Nullable
                Serializable predecessorRes)

Create a task with an execution plan with predecessor result.

Parameters:

destPorts - Destination ports of this TaskData.

executionPlan - A global execution plan.

predecessorRes - Result of the predecessor node, which is a serializable object.

Method Detail

getDestNode

@Nullable
public TaskData.ExecutionPlan.Node getDestNode(Stream.Port port)

Get the destination node which contains the given port.

Parameters:

port - the port of the node which is one of the destination nodes in this TaskData

Returns:

the destination node which contains the given port, or null when the port is not in the destination ports.

getDestNode

public TaskData.ExecutionPlan.Node getDestNode(List<Stream.Port> possiblePorts)

Get the destination node which contains the given ports.

Parameters:

possiblePorts - a list of ports of the node which contains at least one of the destination nodes in this TaskData

Returns:

the destination node which contains the given ports, or null when none of the possible ports are in the destination ports.

toString

public String toString()

Overrides:

toString in class Object