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

Class BigDecimalCumSumOperator

java.lang.Object

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

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

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

All Implemented Interfaces:

UpdateByOperator

public final class BigDecimalCumSumOperator
extends BaseObjectBinaryOperator<BigDecimal>

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
BigDecimalCumSumOperator(MatchPair inputPair, RedirectionIndex redirectionIndex, MathContext mathContext)

Method Summary

Modifier and Type	Method	Description
protected BigDecimal	doOperation(BigDecimal bucketCurVal, BigDecimal 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

BigDecimalCumSumOperator

public BigDecimalCumSumOperator(@NotNull
 MatchPair inputPair,
 @Nullable
 RedirectionIndex redirectionIndex,
 @NotNull
 MathContext mathContext)

Method Details

doOperation

protected BigDecimal doOperation(BigDecimal bucketCurVal,
 BigDecimal chunkCurVal)

Specified by:

doOperation in class BaseObjectBinaryOperator<BigDecimal>