public class BGatherExample extends BenchWorker
Modifier and Type | Class and Description |
---|---|
class |
BGatherExample.FinalReduceReceiver |
BenchWorker.MapWorker
experimentData, finishedSources, inputDataArray, jobParameters, logicalPlan, resultsRecorder, sourcesDone, workerId
Constructor and Description |
---|
BGatherExample() |
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) |
execute, generateData, progress, verifyResults
protected void compute(WorkerEnvironment workerEnv)
compute
in class BenchWorker
public void close()
close
in class BenchWorker
protected boolean progressCommunication()
progressCommunication
in class BenchWorker
protected boolean sendMessages(int task, java.lang.Object data, int flag)
sendMessages
in class BenchWorker
protected boolean isDone()
isDone
in class BenchWorker
protected void finishCommunication(int src)
finishCommunication
in class BenchWorker