edu.iu.dsc.tws.task.graph

Class GraphBuilder

java.lang.Object

edu.iu.dsc.tws.task.graph.GraphBuilder

public final class GraphBuilder
extends java.lang.Object

This class is responsible for building the task graph and the configuration values required for each task in the task graph.

Method Summary

Modifier and Type	Method and Description
GraphBuilder	addConfiguration(java.lang.String taskName, java.lang.String property, java.lang.Object value)
GraphBuilder	addSource(java.lang.String name, ISource source)
GraphBuilder	addSource(java.lang.String name, ISource source, int parallelism)
GraphBuilder	addTask(java.lang.String name, ICompute task)
GraphBuilder	addTask(java.lang.String name, ICompute task, int parallelism)
ComputeGraph	build()
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, Edge edge)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation, IFunction task)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation, IFunction function, MessageType dataType, MessageType keyType)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation, IFunction function, MessageType dataType, MessageType keyType, TaskPartitioner partitioner)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation, MessageType dataType)
GraphBuilder	connect(java.lang.String t1, java.lang.String t2, java.lang.String name, java.lang.String operation, MessageType dataType, MessageType keyType)
static GraphBuilder	newBuilder()
ComputeGraph	operationMode(OperationMode mode) Set the operation mode of the graph, default is set to stream
GraphBuilder	setParallelism(java.lang.String taskName, int parallel)
boolean	vertexExists(java.lang.String name)

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static GraphBuilder newBuilder()

addSource

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

addSource

public GraphBuilder addSource(java.lang.String name,
                              ISource source,
                              int parallelism)

addTask

public GraphBuilder addTask(java.lang.String name,
                            ICompute task)

addTask

public GraphBuilder addTask(java.lang.String name,
                            ICompute task,
                            int parallelism)

setParallelism

public GraphBuilder setParallelism(java.lang.String taskName,
                                   int parallel)

addConfiguration

public GraphBuilder addConfiguration(java.lang.String taskName,
                                     java.lang.String property,
                                     java.lang.Object value)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation,
                            IFunction task)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation,
                            MessageType dataType,
                            MessageType keyType)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation,
                            IFunction function,
                            MessageType dataType,
                            MessageType keyType)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation,
                            IFunction function,
                            MessageType dataType,
                            MessageType keyType,
                            TaskPartitioner partitioner)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            java.lang.String name,
                            java.lang.String operation,
                            MessageType dataType)

connect

public GraphBuilder connect(java.lang.String t1,
                            java.lang.String t2,
                            Edge edge)

build

public ComputeGraph build()

operationMode

public ComputeGraph operationMode(OperationMode mode)

Set the operation mode of the graph, default is set to stream

vertexExists

public boolean vertexExists(java.lang.String name)