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

Class KGatherStreamingPartialReceiver

java.lang.Object

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

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

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

All Implemented Interfaces:

MessageReceiver

public class KGatherStreamingPartialReceiver
extends KGatherStreamingReceiver

Abstract class that is extended by keyed reduce batch receivers

Field Summary

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.gather.keyed.KGatherStreamingReceiver

localWindowCount, 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
KGatherStreamingPartialReceiver(int dest, int limitPerKey, int windowSize)

Method Summary

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.gather.keyed.KGatherStreamingReceiver

isAllQueuesEmpty, offerMessage, sendToTarget

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

checkIfEmptyIsSent, finishProgress, init, isComplete, isSourcesFinished, moveMessagesToSendQueue, moveMessageToSendQueue, 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

clean, close, onMessage

Constructor Detail

KGatherStreamingPartialReceiver

public KGatherStreamingPartialReceiver(int dest,
                                       int limitPerKey,
                                       int windowSize)