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

Class KReduceBatchPartialReceiver

java.lang.Object

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

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

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

All Implemented Interfaces:

MessageReceiver

public class KReduceBatchPartialReceiver
extends KReduceBatchReceiver

Keyed reduce receiver for batch mode

Field Summary

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

reduceFunction

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

batchDone, dataFlowOperation, destination, executor, finishedSources, isEmptySent, isFinalBatchReceiver, keyLimit, limitPerKey, messages, representSource, representSourceSet, sendQueue, thisSources

Constructor Summary

Constructors

Constructor and Description
KReduceBatchPartialReceiver(int dest, ReduceFunction function)

Method Summary

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

moveMessagesToSendQueue, offerMessage

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

checkIfEmptyIsSent, finishProgress, init, isAllQueuesEmpty, isComplete, isSourcesFinished, moveMessageToSendQueue, onFinish, onMessage, progress, sendToTarget

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

clean, close, onMessage

Constructor Detail

KReduceBatchPartialReceiver

public KReduceBatchPartialReceiver(int dest,
                                   ReduceFunction function)