org.cripac.isee.vpe.ctrl

Class TaskData.ExecutionPlan.Node

java.lang.Object

org.cripac.isee.vpe.ctrl.TaskData.ExecutionPlan.Node

All Implemented Interfaces:

Serializable, Cloneable

Enclosing class:

TaskData.ExecutionPlan

public static class TaskData.ExecutionPlan.Node
extends Object
implements Serializable, Cloneable

Each node represents a flow of DStreams in an application. Each node should produce only one kind of output. Note that an application may contain more than one node.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TaskData.ExecutionPlan.Node.Port IO port of a node.

Field Summary

Fields

Modifier and Type	Field and Description
private Serializable	execData The data for this execution.
private boolean	executed Marker recording whether the stream in this execution plan has been executed.
private int	id
private List<TaskData.ExecutionPlan.Node.Port>	outputPorts Each node has its own successor nodes, each organized in a list.
(package private) DataType	outputType
private static long	serialVersionUID

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Node(int id, DataType outputType, Serializable execData)

Method Summary

Modifier and Type	Method and Description
TaskData.ExecutionPlan.Node.Port	createInputPort(Stream.Port prototype)
Serializable	getExecData()
List<TaskData.ExecutionPlan.Node.Port>	getOutputPorts()
boolean	isExecuted()
private void	makeEmpty() Empty the data in the node for saving memory.
void	markExecuted() Mark the stream as executed in the execution plan and clear its data.
void	outputTo(TaskData.ExecutionPlan.Node.Port port)

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

outputPorts

private List<TaskData.ExecutionPlan.Node.Port> outputPorts

Each node has its own successor nodes, each organized in a list. The indexes of the set correspond to that of the nodes.

id

private final int id

outputType

final DataType outputType

executed

private boolean executed

Marker recording whether the stream in this execution plan has been executed.

execData

private Serializable execData

The data for this execution.

Constructor Detail

Node

private Node(int id,
             @Nonnull
             DataType outputType,
             @Nullable
             Serializable execData)

Parameters:

execData - The data for execution, which is a serializable

Method Detail

outputTo

public void outputTo(@Nonnull
                     TaskData.ExecutionPlan.Node.Port port)

getOutputPorts

public List<TaskData.ExecutionPlan.Node.Port> getOutputPorts()

Returns:

Successor nodes of this node.

getExecData

public Serializable getExecData()

Returns:

Execution data of this node.

isExecuted

public boolean isExecuted()

Returns:

Whether the node has been executed in this execution plan.

makeEmpty

private void makeEmpty()

Empty the data in the node for saving memory.

markExecuted

public void markExecuted()

Mark the stream as executed in the execution plan and clear its data.

createInputPort

public TaskData.ExecutionPlan.Node.Port createInputPort(Stream.Port prototype)