Class LongCumProdOperator
java.lang.Object
io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
io.deephaven.engine.table.impl.updateby.prod.LongCumProdOperator
- All Implemented Interfaces:
UpdateByOperator
public class LongCumProdOperator extends BaseLongUpdateByOperator
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
BaseLongUpdateByOperator.Context
Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.UpdateByOperator
UpdateByOperator.UpdateContext
-
Field Summary
Fields inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
affectingColumns, bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, pair, singletonGroup, singletonVal
Fields inherited from interface io.deephaven.engine.table.impl.UpdateByOperator
ZERO_LENGTH_OP_ARRAY
-
Constructor Summary
Constructors Constructor Description LongCumProdOperator(MatchPair inputPair, RowRedirection rowRedirection)
-
Method Summary
Modifier and Type Method Description void
addChunk(UpdateByOperator.UpdateContext context, Chunk<Values> values, LongChunk<? extends RowKeys> keyChunk, IntChunk<RowKeys> bucketPositions, IntChunk<ChunkPositions> startPositions, IntChunk<ChunkLengths> runLengths)
Add a chunk of bucketed items to the operation.protected void
doAddChunk(BaseLongUpdateByOperator.Context ctx, RowSequence inputKeys, Chunk<Values> workingChunk, long groupPosition)
Add a chunk of values to the operator.Methods inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
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
-
Constructor Details
-
LongCumProdOperator
-
-
Method Details
-
addChunk
public void addChunk(@NotNull UpdateByOperator.UpdateContext context, @NotNull Chunk<Values> values, @NotNull LongChunk<? extends RowKeys> keyChunk, @NotNull IntChunk<RowKeys> bucketPositions, @NotNull IntChunk<ChunkPositions> startPositions, @NotNull IntChunk<ChunkLengths> runLengths)Description copied from interface:UpdateByOperator
Add a chunk of bucketed items to the operation.- Parameters:
context
- the context objectvalues
- the value chunkkeyChunk
- a chunk of keys for the rows being addedbucketPositions
- a chunk of hash bucket positions for each keystartPositions
- the start position of a run within the chunkrunLengths
- the runLengths of each run of bucket values
-
doAddChunk
protected void doAddChunk(@NotNull BaseLongUpdateByOperator.Context ctx, @NotNull RowSequence inputKeys, @NotNull Chunk<Values> workingChunk, long groupPosition)Description copied from class:BaseLongUpdateByOperator
Add a chunk of values to the operator.- Specified by:
doAddChunk
in classBaseLongUpdateByOperator
- Parameters:
ctx
- the context objectinputKeys
- the input keys for the chunkworkingChunk
- the chunk of valuesgroupPosition
- the bucket position that the values belong to.
-