Package com.illumon.iris.db.v2.updateby.minmax

Class ComparableCumMinMaxOperator<T extends Comparable<T>>

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator<T>

com.illumon.iris.db.v2.updateby.internal.BaseObjectBinaryOperator<T>

com.illumon.iris.db.v2.updateby.minmax.ComparableCumMinMaxOperator<T>

All Implemented Interfaces:

UpdateByOperator

public final class ComparableCumMinMaxOperator<T extends Comparable<T>>
extends BaseObjectBinaryOperator<T>

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

BaseObjectUpdateByOperator.Context

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

UpdateByOperator.UpdateContext

Field Summary

Fields inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

affectingColumns, bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, pair, singletonGroup, singletonVal

Fields inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
ComparableCumMinMaxOperator(Class<T> colType, MatchPair inputPair, boolean isMax, RedirectionIndex redirectionIndex)

Method Summary

Modifier and Type	Method	Description
protected T	doOperation(T bucketCurVal, T chunkCurVal)

Methods inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectBinaryOperator

accumulate, addChunk, doAddChunk

Methods inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

addChunk, anyModified, applyOutputShift, applyShift, canProcessNormalUpdate, finishFor, getAdditionalModifications, getAffectingColumnNames, getInputColumnName, getOutputColumnNames, getOutputColumns, initializeFor, initializeForUpdate, makeUpdateContext, modifyChunk, onBucketsRemoved, removeChunk, reprocessChunk, reprocessChunk, requiresKeys, requiresValues, resetForReprocess, resetForReprocess, setBucketCapacity, setChunkSize, startTrackingPrev

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ComparableCumMinMaxOperator

public ComparableCumMinMaxOperator(Class<T> colType,
 @NotNull
 MatchPair inputPair,
 boolean isMax,
 @Nullable
 RedirectionIndex redirectionIndex)

Method Details

doOperation

protected T doOperation(T bucketCurVal,
 T chunkCurVal)

Specified by:

doOperation in class BaseObjectBinaryOperator<T extends Comparable<T>>