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

Class KReduceStreamingPartialReceiver

java.lang.Object

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

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

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

All Implemented Interfaces:

MessageReceiver

public class KReduceStreamingPartialReceiver
extends KReduceStreamingReceiver

Keyed reduce partial receiver for streaming mode

Field Summary

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

localWindowCount, reduceFunction, windowSize

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
KReduceStreamingPartialReceiver(int dest, ReduceFunction function, int window)

Method Summary

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

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

KReduceStreamingPartialReceiver

public KReduceStreamingPartialReceiver(int dest,
                                       ReduceFunction function,
                                       int window)