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

Class ComparableStaticCumMinMaxOperator<T extends Comparable<T>>

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.AbstractStaticUpdateByOperator

com.illumon.iris.db.v2.updateby.BaseObjectBinaryStaticOperator<T>

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

All Implemented Interfaces:

ChunkedUpdateByOperator

public final class ComparableStaticCumMinMaxOperator<T extends Comparable<T>>
extends BaseObjectBinaryStaticOperator<T>

Nested Class Summary

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

ChunkedUpdateByOperator.BucketedUpdateContext, ChunkedUpdateByOperator.UpdateContext

Field Summary

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

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
ComparableStaticCumMinMaxOperator(Class<T> colType, MatchPair inputPair, boolean isMax)

Method Summary

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

Methods inherited from class com.illumon.iris.db.v2.updateby.BaseObjectBinaryStaticOperator

addChunk, addChunk, getInputColumnName, getOutputColumnNames, getOutputColumns, initializeFor, initializeFor, makeBucketedContext, makeUpdateContext, setBucketCapacity

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

anyModified, anyModified, applyShift, finishFor, finishFor, getAdditionalModifications, modifyChunk, removeChunk, setUpstream, setUpstream, startTrackingPrev

Methods inherited from class java.lang.Object

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

Constructor Details

ComparableStaticCumMinMaxOperator

public ComparableStaticCumMinMaxOperator(Class<T> colType, @NotNull MatchPair inputPair, boolean isMax)

Method Details

doOperation

protected T doOperation(T bucketCurVal, T chunkCurVal)

Specified by:

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