edu.iu.dsc.tws.examples.comms.stream

Class SKeyedGatherExample

java.lang.Object

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

edu.iu.dsc.tws.examples.comms.stream.SKeyedGatherExample

All Implemented Interfaces:

Twister2Worker

public class SKeyedGatherExample
extends KeyedBenchWorker

todo not applicable for streaming, without window

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SKeyedGatherExample.GatherBulkReceiver

Nested classes/interfaces inherited from class edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

KeyedBenchWorker.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
SKeyedGatherExample()

Method Summary

Modifier and Type	Method and Description
protected void	compute(WorkerEnvironment workerEnv)
protected boolean	isDone()
protected boolean	progressCommunication()
protected boolean	sendMessages(int task, java.lang.Object key, java.lang.Object data, int flag)

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

close, execute, finishCommunication, progress, verifyResults

Methods inherited from class java.lang.Object

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

Constructor Detail

SKeyedGatherExample

public SKeyedGatherExample()

Method Detail

compute

protected void compute(WorkerEnvironment workerEnv)

Specified by:

compute in class KeyedBenchWorker

progressCommunication

protected boolean progressCommunication()

Specified by:

progressCommunication in class KeyedBenchWorker

isDone

protected boolean isDone()

Specified by:

isDone in class KeyedBenchWorker

sendMessages

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

Specified by:

sendMessages in class KeyedBenchWorker