edu.iu.dsc.tws.examples.comms

Class KeyedBenchWorker

java.lang.Object

edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

All Implemented Interfaces:

Twister2Worker

Direct Known Subclasses:

BDKeyedGatherExample, BJoinStudentExample, BKeyedGatherExample, BKeyedPartitionExample, BKeyedReduceExample, JoinedKeyedBenchWorker, SKeyedGatherExample, SKeyedPartitionExample, SKeyedReduceExample

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

BenchWorker class that works with keyed operations

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	KeyedBenchWorker.MapWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected ExperimentData	experimentData
protected java.util.Map<java.lang.Integer,java.lang.Boolean>	finishedSources
protected int[]	inputDataArray
protected JobParameters	jobParameters
protected LogicalPlan	logicalPlan
protected BenchmarkResultsRecorder	resultsRecorder
protected boolean	sourcesDone
protected int	workerId

Constructor Summary

Constructors

Constructor and Description
KeyedBenchWorker()

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract void	compute(WorkerEnvironment wEnv)
void	execute(WorkerEnvironment workerEnvironment) This is the main point of entry for Twister2 jobs.
protected void	finishCommunication(int src)
protected abstract boolean	isDone()
protected void	progress()
protected abstract boolean	progressCommunication()
protected abstract boolean	sendMessages(int task, java.lang.Object key, java.lang.Object data, int flag)
protected void	verifyResults(ResultsVerifier resultsVerifier, java.lang.Object results, java.util.Map<java.lang.String,java.lang.Object> args) 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

workerId

protected int workerId

logicalPlan

protected LogicalPlan logicalPlan

jobParameters

protected JobParameters jobParameters

finishedSources

protected final java.util.Map<java.lang.Integer,java.lang.Boolean> finishedSources

sourcesDone

protected boolean sourcesDone

experimentData

protected ExperimentData experimentData

inputDataArray

protected int[] inputDataArray

resultsRecorder

protected BenchmarkResultsRecorder resultsRecorder

Constructor Detail

KeyedBenchWorker

public KeyedBenchWorker()

Method Detail

execute

public void execute(WorkerEnvironment workerEnvironment)

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

compute

protected abstract void compute(WorkerEnvironment wEnv)

progress

protected void progress()

verifyResults

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

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

close

public void close()

progressCommunication

protected abstract boolean progressCommunication()

isDone

protected abstract boolean isDone()

sendMessages

protected abstract boolean sendMessages(int task,
                                        java.lang.Object key,
                                        java.lang.Object data,
                                        int flag)

finishCommunication

protected void finishCommunication(int src)