edu.iu.dsc.tws.examples.task

Class BenchWindowTaskWorker

java.lang.Object

edu.iu.dsc.tws.task.impl.TaskWorker

edu.iu.dsc.tws.examples.task.BenchWindowTaskWorker

All Implemented Interfaces:

IWorker

public abstract class BenchWindowTaskWorker
extends TaskWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BenchWindowTaskWorker.SourceWindowTask

Field Summary

Fields

Modifier and Type	Field and Description
protected ComputeConnection	computeConnection
protected ComputeGraph	computeGraph
protected ComputeGraphBuilder	computeGraphBuilder
protected ExecutionPlan	executionPlan
protected static int[]	inputDataArray
protected static JobParameters	jobParameters
protected static BenchmarkResultsRecorder	resultsRecorder
protected static java.lang.String	SINK
protected static java.lang.String	SOURCE

Fields inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId

Constructor Summary

Constructors

Constructor and Description
BenchWindowTaskWorker()

Method Summary

Modifier and Type	Method and Description
abstract ComputeGraphBuilder	buildTaskGraph()
void	execute() A user needs to implement this method to create the task graph and execute it

Methods inherited from class edu.iu.dsc.tws.task.impl.TaskWorker

execute

Methods inherited from class java.lang.Object

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

Field Detail

SOURCE

protected static final java.lang.String SOURCE

See Also:

Constant Field Values

SINK

protected static final java.lang.String SINK

See Also:

Constant Field Values

computeGraph

protected ComputeGraph computeGraph

computeGraphBuilder

protected ComputeGraphBuilder computeGraphBuilder

executionPlan

protected ExecutionPlan executionPlan

computeConnection

protected ComputeConnection computeConnection

jobParameters

protected static JobParameters jobParameters

inputDataArray

protected static int[] inputDataArray

resultsRecorder

protected static BenchmarkResultsRecorder resultsRecorder

Constructor Detail

BenchWindowTaskWorker

public BenchWindowTaskWorker()

Method Detail

execute

public void execute()

Description copied from class: TaskWorker

A user needs to implement this method to create the task graph and execute it

Specified by:

execute in class TaskWorker

buildTaskGraph

public abstract ComputeGraphBuilder buildTaskGraph()