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

Class BigIntegerCumSumOperator

java.lang.Object

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

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

com.illumon.iris.db.v2.updateby.sum.BigIntegerCumSumOperator

All Implemented Interfaces:

UpdateByOperator

public final class BigIntegerCumSumOperator
extends BaseObjectBinaryOperator<BigInteger>

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
BigIntegerCumSumOperator(MatchPair inputPair, RedirectionIndex redirectionIndex)

Method Summary

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

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

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

BigIntegerCumSumOperator

public BigIntegerCumSumOperator(@NotNull MatchPair inputPair, @Nullable RedirectionIndex redirectionIndex)

Method Details

doOperation

protected BigInteger doOperation(BigInteger bucketCurVal, BigInteger chunkCurVal)

Specified by:

doOperation in class BaseObjectBinaryOperator<BigInteger>