edu.iu.dsc.tws.examples.task

Class BenchTaskWorker

java.lang.Object

edu.iu.dsc.tws.examples.task.BenchTaskWorker

All Implemented Interfaces:

Twister2Worker

Direct Known Subclasses:

BTAllGatherExample, BTAllReduceExample, BTBroadCastExample, BTDirectExample, BTGatherExample, BTJoinExample, BTKeyedGatherExample, BTKeyedReduceExample, BTPartitionExample, BTPartitionKeyedExample, BTReduceExample, STAllGatherExample, STAllReduceExample, STBroadCastExample, STGatherExample, STKeyedGatherExample, STKeyedReduceExample, STPartitionExample, STPartitionKeyedExample, STReduceExample, STWindowCustomExample, STWindowEventTimeExample, STWindowExample, STWindowMPI

public abstract class BenchTaskWorker
extends java.lang.Object
implements Twister2Worker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BenchTaskWorker.SourceTask
protected static class	BenchTaskWorker.SourceWindowTask
protected static class	BenchTaskWorker.SourceWindowTimeStampTask

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 java.util.concurrent.atomic.AtomicInteger	receiversInProgress
protected static BenchmarkResultsRecorder	resultsRecorder
protected static java.util.concurrent.atomic.AtomicInteger	sendersInProgress
protected static java.lang.String	SINK
protected static java.lang.String	SOURCE

Constructor Summary

Constructors

Constructor and Description
BenchTaskWorker()

Method Summary

Modifier and Type	Method and Description
abstract ComputeGraphBuilder	buildTaskGraph()
void	execute(WorkerEnvironment workerEnv) This is the main point of entry for Twister2 jobs.
static boolean	getTimingCondition(java.lang.String taskName, TaskContext ctx)
protected static boolean	verifyResults(ResultsVerifier resultsVerifier, java.lang.Object results, java.util.Map<java.lang.String,java.lang.Object> args, boolean verified) This method will verify results and append the output to the results recorder

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

sendersInProgress

protected static java.util.concurrent.atomic.AtomicInteger sendersInProgress

receiversInProgress

protected static java.util.concurrent.atomic.AtomicInteger receiversInProgress

Constructor Detail

BenchTaskWorker

public BenchTaskWorker()

Method Detail

execute

public void execute(WorkerEnvironment workerEnv)

Description copied from interface: Twister2Worker

This is the main point of entry for Twister2 jobs. Every job should implement this interface. When a job is submitted, a class implementing this interface gets instantiated and executed by Twister2. As the first thing in the execute method, users are expected to initialize the proper environment object: for batch jobs: BatchTSetEnvironment for streaming jobs: StreamingTSetEnvironment

Specified by:

execute in interface Twister2Worker

buildTaskGraph

public abstract ComputeGraphBuilder buildTaskGraph()

verifyResults

protected static boolean verifyResults(ResultsVerifier resultsVerifier,
                                       java.lang.Object results,
                                       java.util.Map<java.lang.String,java.lang.Object> args,
                                       boolean verified)

This method will verify results and append the output to the results recorder

getTimingCondition

public static boolean getTimingCondition(java.lang.String taskName,
                                         TaskContext ctx)