org.cripac.isee.vpe.ctrl

Class TaskData.ExecutionPlan

java.lang.Object

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

All Implemented Interfaces:

Serializable, Cloneable

Enclosing class:

TaskData

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

The ExecutionPlan class represents a directed acyclic graph of the execution flows of modules. Each node is an execution of a module. Each link represents that an execution should output to a next execution node. One module may exist multiple times in a graph.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskData.ExecutionPlan.Node Each node represents a flow of DStreams in an application.

Field Summary

Fields

Modifier and Type	Field and Description
private int	nodeIDCounter
private Map<Integer,TaskData.ExecutionPlan.Node>	nodes Map for finding nodes according to the class of its module.
private static long	serialVersionUID

Constructor Summary

Constructors

Constructor and Description
ExecutionPlan()

Method Summary

Modifier and Type	Method and Description
TaskData.ExecutionPlan.Node	addNode(DataType outputType) Add a node to the execution plan.
(package private) TaskData.ExecutionPlan.Node	addNode(DataType outputType, Serializable execData) Add a node to the execution plan.
void	combine(TaskData.ExecutionPlan planToCombine) Combine two execution plans.
protected void	finalize()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

nodes

private Map<Integer,TaskData.ExecutionPlan.Node> nodes

Map for finding nodes according to the class of its module.

nodeIDCounter

private int nodeIDCounter

Constructor Detail

ExecutionPlan

public ExecutionPlan()

Method Detail

combine

public void combine(@Nonnull
                    TaskData.ExecutionPlan planToCombine)

Combine two execution plans. If a node is marked executed in either plan, the corresponding node in the combined plan is also marked executed.

Parameters:

planToCombine - Another plan to combine on this plan.

toString

public String toString()

Overrides:

toString in class Object

addNode

public TaskData.ExecutionPlan.Node addNode(@Nonnull
                                           DataType outputType)

Add a node to the execution plan. If it has been added previously with no execution data, the new execution data will be added to the previous node.

Parameters:

outputType - Output data type of the node.

Returns:

The new added node.

addNode

TaskData.ExecutionPlan.Node addNode(@Nonnull
                                    DataType outputType,
                                    @Nullable
                                    Serializable execData)

Add a node to the execution plan. If it has been added previously with no execution data, the new execution data will be added to the previous node.

Parameters:

outputType - Output data type of the node.

execData - Data for execution of the node.

Returns:

The new added node.

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable