public class PartitionPartialReceiver extends TargetPartialReceiver
barriers, sourceStates, stateCleared, syncSent
destination, groupingSize, highWaterMark, lock, messages, operation, representSource, syncState, targets, thisDestinations, thisSources, workerId
Constructor and Description |
---|
PartitionPartialReceiver() |
Modifier and Type | Method and Description |
---|---|
protected void |
addSyncMessage(int source,
int target)
Add a sync message
|
void |
clean()
Clean any state associated with the receiver and go to initial state
|
void |
init(Config cfg,
DataFlowOperation op,
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)
Initialize the message receiver with tasks from which messages are expected
For each sub edge in graph, for each path, gives the expected task ids
|
protected boolean |
isFilledToSend(int target)
Return true if we are filled to send
|
addMessage, addSyncMessageBarrier, canAcceptMessage, isComplete, merge, onSyncEvent, progress, sendToTarget, sync
clearTarget, onMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, onMessage
public void init(Config cfg, DataFlowOperation op, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)
MessageReceiver
target -> source tasks
init
in interface MessageReceiver
init
in class TargetPartialReceiver
expectedIds
- expected task idsprotected void addSyncMessage(int source, int target)
TargetReceiver
addSyncMessage
in class TargetPartialReceiver
source
- sourcetarget
- targetprotected boolean isFilledToSend(int target)
TargetReceiver
isFilledToSend
in class TargetPartialReceiver
public void clean()
MessageReceiver
clean
in interface MessageReceiver
clean
in class TargetPartialReceiver