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

Class KReduceStreamingFinalReceiver

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.KReduceStreamingFinalReceiver

All Implemented Interfaces:

MessageReceiver

public class KReduceStreamingFinalReceiver
extends KReduceStreamingReceiver

Keyed reduce final 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
KReduceStreamingFinalReceiver(ReduceFunction reduce, SingularReceiver receiver, int window)

Method Summary

Modifier and Type	Method and Description
boolean	progress() Default progress method for keyed receivers.

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, 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

KReduceStreamingFinalReceiver

public KReduceStreamingFinalReceiver(ReduceFunction reduce,
                                     SingularReceiver receiver,
                                     int window)

Method Detail

progress

public boolean progress()

Description copied from class: KeyedReceiver

Default progress method for keyed receivers. This method is targeted at partial receivers which typically execute the same logic. For custom progress logic this method needs to be overwritten

Specified by:

progress in interface MessageReceiver

Overrides:

progress in class KeyedReceiver

Returns:

true if needs further communicationProgress