Class DoubleCumProdOperator
java.lang.Object
io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator
io.deephaven.engine.table.impl.updateby.prod.DoubleCumProdOperator
- All Implemented Interfaces:
UpdateByOperator
public class DoubleCumProdOperator extends BaseDoubleUpdateByOperator
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator
BaseDoubleUpdateByOperator.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.BaseDoubleUpdateByOperator
bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, singletonGroup, singletonVal
Fields inherited from interface io.deephaven.engine.table.impl.UpdateByOperator
ZERO_LENGTH_OP_ARRAY
-
Constructor Summary
Constructors Constructor Description DoubleCumProdOperator(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(BaseDoubleUpdateByOperator.Context ctx, RowSequence inputKeys, Chunk<Values> workingChunk, long groupPosition)
Methods inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator
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
-
DoubleCumProdOperator
public DoubleCumProdOperator(@NotNull MatchPair inputPair, @Nullable RowRedirection rowRedirection)
-
-
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 BaseDoubleUpdateByOperator.Context ctx, @NotNull RowSequence inputKeys, @NotNull Chunk<Values> workingChunk, long groupPosition)- Specified by:
doAddChunk
in classBaseDoubleUpdateByOperator
-