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