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

Class FloatCumSumOperator

java.lang.Object

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

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

All Implemented Interfaces:

UpdateByOperator

public class FloatCumSumOperator
extends BaseFloatUpdateByOperator

Nested Class Summary

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

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

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

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

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
FloatCumSumOperator(MatchPair pair, RedirectionIndex redirectionIndex)

Method Summary

Modifier and Type	Method	Description
void	addChunk(UpdateByOperator.UpdateContext context, Chunk<Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> keyChunk, IntChunk<Attributes.KeyIndices> bucketPositions, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> runLengths)	Add a chunk of bucketed items to the operation.
protected void	doAddChunk(BaseFloatUpdateByOperator.Context ctx, OrderedKeys inputKeys, Chunk<Attributes.Values> workingChunk, long groupPosition)

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

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

FloatCumSumOperator

public FloatCumSumOperator(@NotNull
 MatchPair pair,
 @Nullable
 RedirectionIndex redirectionIndex)

Method Details

addChunk

public void addChunk(@NotNull
 UpdateByOperator.UpdateContext context,
 @NotNull
 Chunk<Attributes.Values> values,
 @NotNull
 LongChunk<? extends Attributes.KeyIndices> keyChunk,
 @NotNull
 IntChunk<Attributes.KeyIndices> bucketPositions,
 @NotNull
 IntChunk<Attributes.ChunkPositions> startPositions,
 @NotNull
 IntChunk<Attributes.ChunkLengths> runLengths)

Description copied from interface: UpdateByOperator

Add a chunk of bucketed items to the operation.

Parameters:

context - the context object

values - the value chunk

keyChunk - a chunk of keys for the rows being added

bucketPositions - a chunk of hash bucket positions for each key

startPositions - the start position of a run within the chunk

runLengths - the runLengths of each run of bucket values

doAddChunk

protected void doAddChunk(@NotNull
 BaseFloatUpdateByOperator.Context ctx,
 @NotNull
 OrderedKeys inputKeys,
 @NotNull
 Chunk<Attributes.Values> workingChunk,
 long groupPosition)

Specified by:

doAddChunk in class BaseFloatUpdateByOperator