edu.iu.dsc.tws.examples.comms

Class JoinedKeyedBenchWorker

java.lang.Object

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

edu.iu.dsc.tws.examples.comms.JoinedKeyedBenchWorker

All Implemented Interfaces:

Twister2Worker

Direct Known Subclasses:

BDJoinExample, BJoinExample

public abstract class JoinedKeyedBenchWorker
extends KeyedBenchWorker

BenchWorker class that works with keyed join operations, The worker generates two sets of data with a single key type for both

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	JoinedKeyedBenchWorker.MapWorker

Field Summary

Fields inherited from class edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

experimentData, finishedSources, inputDataArray, jobParameters, logicalPlan, resultsRecorder, sourcesDone, workerId

Constructor Summary

Constructors

Constructor and Description
JoinedKeyedBenchWorker()

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	sendMessages(int task, java.lang.Object key, java.lang.Object data, int flag, int tag)

Methods inherited from class edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

close, compute, execute, finishCommunication, isDone, progress, progressCommunication, sendMessages, verifyResults

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinedKeyedBenchWorker

public JoinedKeyedBenchWorker()

Method Detail

sendMessages

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