public abstract class JoinedKeyedBenchWorker extends KeyedBenchWorker
Modifier and Type | Class and Description |
---|---|
protected class |
JoinedKeyedBenchWorker.MapWorker |
experimentData, finishedSources, inputDataArray, jobParameters, logicalPlan, resultsRecorder, sourcesDone, workerId
Constructor and Description |
---|
JoinedKeyedBenchWorker() |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
sendMessages(int task,
java.lang.Object key,
java.lang.Object data,
int flag,
int tag) |
close, compute, execute, finishCommunication, isDone, progress, progressCommunication, sendMessages, verifyResults