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

Class BaseReduceBatchFinalReceiver

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

All Implemented Interfaces:

MessageReceiver

Direct Known Subclasses:

AllReduceBatchFinalReceiver, ReduceBatchFinalReceiver

public abstract class BaseReduceBatchFinalReceiver
extends ReduceBatchReceiver

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
BaseReduceBatchFinalReceiver(ReduceFunction reduce)

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	handleFinished(int task, java.lang.Object value) Handle finish
boolean	handleMessage(int source, java.lang.Object message, int flags, int dest)

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

aggregate, init, isAllEmpty, isFilledToSend, onSyncEvent, sendToTarget

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

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

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

BaseReduceBatchFinalReceiver

public BaseReduceBatchFinalReceiver(ReduceFunction reduce)

Method Detail

handleMessage

public boolean handleMessage(int source,
                             java.lang.Object message,
                             int flags,
                             int dest)

Specified by:

handleMessage in class ReduceBatchReceiver

handleFinished

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

Handle finish

Parameters:

task - task

value - value

Returns:

true if success