edu.iu.dsc.tws.task.impl

Class ComputeGraphBuilder

java.lang.Object

edu.iu.dsc.tws.task.impl.ComputeGraphBuilder

public final class ComputeGraphBuilder
extends java.lang.Object

This is the entry point for creating a task graph by the user.

Method Summary

Modifier and Type	Method and Description
ComputeConnection	addCompute(java.lang.String name, ICompute compute) Add a compute node to the graph
ComputeConnection	addCompute(java.lang.String name, ICompute compute, int parallel) Add a compute node to the graph
java.util.Map<java.lang.String,java.lang.String>	addGraphConstraints(java.util.Map<java.lang.String,java.lang.String> graphconstraints) Adding Graph Constraints
java.util.Map<java.lang.String,java.lang.String>	addGraphConstraints(java.lang.String constraintName, java.lang.String constraintValue) Adding Graph Constraints
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	addNodeConstraints(java.lang.String nodeName, java.util.Map<java.lang.String,java.lang.String> nodeconstraints)
SourceConnection	addSource(java.lang.String name, ISource source) Add a source node to the graph
SourceConnection	addSource(java.lang.String name, ISource source, int parallel) Add a source node to the graph
ComputeGraph	build()
OperationMode	getMode() Get the operation mode
static ComputeGraphBuilder	newBuilder(Config cfg) Create an instance of the task builder.
void	setMode(OperationMode mode) Set the operation mode, we default to streaming mode
void	setTaskGraphName(java.lang.String taskGraphName)

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static ComputeGraphBuilder newBuilder(Config cfg)

Create an instance of the task builder.

Parameters:

cfg - configuration

Returns:

new task graph builder instance

setMode

public void setMode(OperationMode mode)

Set the operation mode, we default to streaming mode

Parameters:

mode - the operation mode (streaming, batch)

setTaskGraphName

public void setTaskGraphName(java.lang.String taskGraphName)

addCompute

public ComputeConnection addCompute(java.lang.String name,
                                    ICompute compute)

Add a compute node to the graph

Parameters:

name - name of the node

compute - number of parallel instances

Returns:

a compute connection, that can be used to connect this node to other nodes as a child

addCompute

public ComputeConnection addCompute(java.lang.String name,
                                    ICompute compute,
                                    int parallel)

Add a compute node to the graph

Parameters:

name - name of the node

compute - implementation of the node

parallel - number of parallel instances

Returns:

a compute connection, that can be used to connect this node to other nodes as a child

addSource

public SourceConnection addSource(java.lang.String name,
                                  ISource source)

Add a source node to the graph

Parameters:

name - name of the node

source - implementation of the node

Returns:

a compute connection, that can be used to connect this node to other nodes as a child

addSource

public SourceConnection addSource(java.lang.String name,
                                  ISource source,
                                  int parallel)

Add a source node to the graph

Parameters:

name - name of the node

source - implementation of the node

parallel - parallelism of the node

Returns:

a compute connection, that can be used to connect this node to other nodes as a child

getMode

public OperationMode getMode()

Get the operation mode

Returns:

the operation mode

addGraphConstraints

public java.util.Map<java.lang.String,java.lang.String> addGraphConstraints(java.lang.String constraintName,
                                                                            java.lang.String constraintValue)

Adding Graph Constraints

addGraphConstraints

public java.util.Map<java.lang.String,java.lang.String> addGraphConstraints(java.util.Map<java.lang.String,java.lang.String> graphconstraints)

Adding Graph Constraints

addNodeConstraints

public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> addNodeConstraints(java.lang.String nodeName,
                                                                                                           java.util.Map<java.lang.String,java.lang.String> nodeconstraints)

build

public ComputeGraph build()