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

Class ReduceBatchFinalReceiver

java.lang.Object

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

edu.iu.dsc.tws.comms.dfw.io.reduce.ReduceBatchReceiver

edu.iu.dsc.tws.comms.dfw.io.reduce.BaseReduceBatchFinalReceiver

edu.iu.dsc.tws.comms.dfw.io.reduce.ReduceBatchFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class ReduceBatchFinalReceiver
extends BaseReduceBatchFinalReceiver

Field Summary

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

reducedValueMap, reduceFunction

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

barriers, destination, isSyncSent, messages, operation, sendPendingMax, sourcesOfTarget, syncReceived, syncState, targetStates, workerId

Constructor Summary

Constructors

Constructor and Description
ReduceBatchFinalReceiver(ReduceFunction reduce, SingularReceiver receiver)

Method Summary

Modifier and Type	Method and Description
protected boolean	handleFinished(int task, java.lang.Object value) Handle finish
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 void	onSyncEvent(int target, byte[] value) This method is called when there is a sync event on the operation
protected boolean	sendSyncForward(int target) Handle the sync

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

handleMessage

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

aggregate, isAllEmpty, isFilledToSend, sendToTarget

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

allQueuesEmpty, allSyncsPresent, clean, isComplete, onFinish, onMessage, progress

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

ReduceBatchFinalReceiver

public ReduceBatchFinalReceiver(ReduceFunction reduce,
                                SingularReceiver receiver)

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 ReduceBatchReceiver

expectedIds - expected task ids

handleFinished

protected boolean handleFinished(int task,
                                 java.lang.Object value)

Description copied from class: BaseReduceBatchFinalReceiver

Handle finish

Specified by:

handleFinished in class BaseReduceBatchFinalReceiver

Parameters:

task - task

value - value

Returns:

true if success

sendSyncForward

protected boolean sendSyncForward(int target)

Description copied from class: SourceReceiver

Handle the sync

Specified by:

sendSyncForward in class SourceReceiver

Parameters:

target - target

Returns:

the needFurtherProgress

onSyncEvent

protected void onSyncEvent(int target,
                           byte[] value)

Description copied from class: SourceReceiver

This method is called when there is a sync event on the operation

Overrides:

onSyncEvent in class ReduceBatchReceiver

Parameters:

target - the target to which the sync event belong

value - the byte value, can be null