public class ReduceStreamingPartialReceiver extends ReduceStreamingReceiver
reduceFunction
barriers, destination, isSyncSent, messages, operation, sendPendingMax, sourcesOfTarget, syncReceived, syncState, targetStates, workerId
Constructor and Description |
---|
ReduceStreamingPartialReceiver(int dst,
ReduceFunction function) |
Modifier and Type | Method and Description |
---|---|
boolean |
handleMessage(int source,
java.lang.Object message,
int flags,
int dest) |
protected boolean |
sendSyncForward(int target)
Handle the sync
|
aggregate, init, isAllEmpty, isFilledToSend, onSyncEvent, sendToTarget
allQueuesEmpty, allSyncsPresent, clean, isComplete, onFinish, onMessage, progress
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, onMessage
public ReduceStreamingPartialReceiver(int dst, ReduceFunction function)
public boolean handleMessage(int source, java.lang.Object message, int flags, int dest)
handleMessage
in class ReduceStreamingReceiver
protected boolean sendSyncForward(int target)
SourceReceiver
sendSyncForward
in class ReduceStreamingReceiver
target
- target