Package io.deephaven.engine.table.impl.updateby.prod

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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
BaseDoubleUpdateByOperator.Context ctx,
@NotNull
RowSequence inputKeys,
@NotNull
Chunk<Values> workingChunk,
long groupPosition)

Specified by:

doAddChunk in class BaseDoubleUpdateByOperator