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

Class SPartitionExample

java.lang.Object

edu.iu.dsc.tws.examples.comms.BenchWorker

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

All Implemented Interfaces:

Twister2Worker

public class SPartitionExample
extends BenchWorker

todo add timing, and terminating conditions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SPartitionExample.PartitionReceiver

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

BenchWorker.MapWorker

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
SPartitionExample()

Method Summary

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

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

execute, generateData, progress, verifyResults

Methods inherited from class java.lang.Object

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

Constructor Detail

SPartitionExample

public SPartitionExample()

Method Detail

compute

protected void compute(WorkerEnvironment workerEnv)

Specified by:

compute in class BenchWorker

progressCommunication

protected boolean progressCommunication()

Specified by:

progressCommunication in class BenchWorker

isDone

protected boolean isDone()

Specified by:

isDone in class BenchWorker

close

public void close()

Overrides:

close in class BenchWorker

sendMessages

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

Specified by:

sendMessages in class BenchWorker

finishCommunication

protected void finishCommunication(int src)

Overrides:

finishCommunication in class BenchWorker