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

Class DGatherBatchFinalReceiver

java.lang.Object

edu.iu.dsc.tws.comms.dfw.io.gather.DGatherBatchFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class DGatherBatchFinalReceiver
extends java.lang.Object
implements MessageReceiver

Constructor Summary

Constructors

Constructor and Description
DGatherBatchFinalReceiver(BulkReceiver bulkReceiver, java.lang.String shuffleDir)

Method Summary

Modifier and Type	Method and Description
void	clean() Clean any state associated with the receiver and go to initial state
void	close() Close the receiver
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
boolean	isComplete() Weather we are complete a set of messages
boolean	onMessage(int source, int path, int target, int flags, java.lang.Object object) The actual message callback
boolean	progress() Method used to communicationProgress work

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

onMessage

Constructor Detail

DGatherBatchFinalReceiver

public DGatherBatchFinalReceiver(BulkReceiver bulkReceiver,
                                 java.lang.String shuffleDir)

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

expectedIds - expected task ids

onMessage

public boolean onMessage(int source,
                         int path,
                         int target,
                         int flags,
                         java.lang.Object object)

Description copied from interface: MessageReceiver

The actual message callback

Specified by:

onMessage in interface MessageReceiver

Parameters:

source - the source task

path - the path that is taken by the message, that is intermediate targets

target - the target of this receiver

flags - the communication flags

object - the actual message

Returns:

true if the message is accepted

progress

public boolean progress()

Method used to communicationProgress work

Specified by:

progress in interface MessageReceiver

Returns:

true if needs further communicationProgress

isComplete

public boolean isComplete()

Description copied from interface: MessageReceiver

Weather we are complete a set of messages

Specified by:

isComplete in interface MessageReceiver

Returns:

true if a round is complete with syncs

close

public void close()

Description copied from interface: MessageReceiver

Close the receiver

Specified by:

close in interface MessageReceiver

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