edu.iu.dsc.tws.comms.dfw.io.partition

Class PartitionPartialReceiver

java.lang.Object

edu.iu.dsc.tws.comms.dfw.io.TargetReceiver

edu.iu.dsc.tws.comms.dfw.io.TargetPartialReceiver

edu.iu.dsc.tws.comms.dfw.io.partition.PartitionPartialReceiver

All Implemented Interfaces:

MessageReceiver

public class PartitionPartialReceiver
extends TargetPartialReceiver

This is the partial receiver for the partition operation. Partial receiver is only going to get called for messages going to other destinations We have partial receivers for each actual source, So even if the message is going to be forwarded to a task within the same worker the message will still go through the partial receiver.

Field Summary

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.TargetPartialReceiver

barriers, sourceStates, stateCleared, syncSent

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.TargetReceiver

destination, groupingSize, highWaterMark, lock, messages, operation, representSource, syncState, targets, thisDestinations, thisSources, workerId

Constructor Summary

Constructors

Constructor and Description
PartitionPartialReceiver()

Method Summary

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

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.TargetPartialReceiver

addMessage, addSyncMessageBarrier, canAcceptMessage, isComplete, merge, onSyncEvent, progress, sendToTarget, sync

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.TargetReceiver

clearTarget, onMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.comms.messaging.MessageReceiver

close, onMessage

Constructor Detail

PartitionPartialReceiver

public PartitionPartialReceiver()

Method Detail

init

public void init(Config cfg,
                 DataFlowOperation op,
                 java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)

Description copied from interface: MessageReceiver

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

target -> source tasks

Specified by:

init in interface MessageReceiver

Overrides:

init in class TargetPartialReceiver

expectedIds - expected task ids

addSyncMessage

protected void addSyncMessage(int source,
                              int target)

Description copied from class: TargetReceiver

Add a sync message

Overrides:

addSyncMessage in class TargetPartialReceiver

Parameters:

source - source

target - target

isFilledToSend

protected boolean isFilledToSend(int target)

Description copied from class: TargetReceiver

Return true if we are filled to send

Overrides:

isFilledToSend in class TargetPartialReceiver

Returns:

true if we are filled enough to send

clean

public void clean()

Description copied from interface: MessageReceiver

Clean any state associated with the receiver and go to initial state

Specified by:

clean in interface MessageReceiver

Overrides:

clean in class TargetPartialReceiver