edu.iu.dsc.tws.task

Class ComputeEnvironment

java.lang.Object

edu.iu.dsc.tws.task.ComputeEnvironment

public final class ComputeEnvironment
extends java.lang.Object

Task environment.

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,ExecutionPlan>	build(ComputeGraph... computeGraphs)
TaskExecutor	buildAndExecute(ComputeGraphBuilder computeGraphBuilder) for single task graph runs
void	close() Closes the task environment
TaskExecutor	getTaskExecutor() Use task executor for fine grained task graph manipulations.
static ComputeEnvironment	init(WorkerEnvironment workerEnv) Initialize the compute environment with the worker environment
ComputeGraphBuilder	newTaskGraph(OperationMode operationMode) Create a compute graph builder
ComputeGraphBuilder	newTaskGraph(OperationMode operationMode, java.lang.String name) Create a new task graph builder with a name

Methods inherited from class java.lang.Object

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

Method Detail

getTaskExecutor

public TaskExecutor getTaskExecutor()

Use task executor for fine grained task graph manipulations. For single task graph builds, use @buildAndExecute

Returns:

taskExecutor the current executor

buildAndExecute

public TaskExecutor buildAndExecute(ComputeGraphBuilder computeGraphBuilder)

for single task graph runs

newTaskGraph

public ComputeGraphBuilder newTaskGraph(OperationMode operationMode)

Create a compute graph builder

Parameters:

operationMode - specify the operation mode

Returns:

the graph builder

newTaskGraph

public ComputeGraphBuilder newTaskGraph(OperationMode operationMode,
                                        java.lang.String name)

Create a new task graph builder with a name

Parameters:

operationMode - operation node

name - name of the graph

Returns:

the graph builder

init

public static ComputeEnvironment init(WorkerEnvironment workerEnv)

Initialize the compute environment with the worker environment

Parameters:

workerEnv - worker environment

Returns:

the compute environment

close

public void close()

Closes the task environment

This method should be called at the end of worker

build

public java.util.Map<java.lang.String,ExecutionPlan> build(ComputeGraph... computeGraphs)