Class LongCumProdOperator
java.lang.Object
io.deephaven.engine.table.impl.updateby.UpdateByOperator
io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
io.deephaven.engine.table.impl.updateby.prod.LongCumProdOperator
-
Nested Class Summary
Nested Classes -
Field Summary
Fields inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
maybeInnerSource, outputSource
Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator
affectingColumns, forwardWindowScaleUnits, inputModifiedColumnSet, outputModifiedColumnSet, pair, reverseWindowScaleUnits, rowRedirection, timestampColumnName
-
Constructor Summary
ConstructorsConstructorDescriptionLongCumProdOperator
(@NotNull MatchPair pair, @Nullable RowRedirection rowRedirection) -
Method Summary
Modifier and TypeMethodDescriptionmakeUpdateContext
(int affectedChunkSize, int influencerChunkSize) Make anUpdateByOperator.Context
suitable for use with updates.Methods inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseLongUpdateByOperator
applyOutputShift, clearOutputRows, getOutputColumns, initializeCumulative, prepareForParallelPopulation, startTrackingPrev
Methods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator
createInputModifiedColumnSet, createOutputModifiedColumnSet, extractDownstreamModifiedColumnSet, finishUpdate, getAffectingColumnNames, getFwdWindowUnits, getInputColumnNames, getInputModifiedColumnSet, getOutputColumnNames, getOutputModifiedColumnSet, getPrevWindowUnits, getTimestampColumnName, initializeRolling, requiresRowPositions
-
Constructor Details
-
LongCumProdOperator
public LongCumProdOperator(@NotNull @NotNull MatchPair pair, @Nullable @Nullable RowRedirection rowRedirection)
-
-
Method Details
-
makeUpdateContext
@NotNull public UpdateByOperator.Context makeUpdateContext(int affectedChunkSize, int influencerChunkSize) Description copied from class:UpdateByOperator
Make anUpdateByOperator.Context
suitable for use with updates.- Specified by:
makeUpdateContext
in classUpdateByOperator
- Parameters:
affectedChunkSize
- The maximum size of affected chunks that will be provided during the update.influencerChunkSize
- The maximum size of influencer chunks that will be provided during the update.- Returns:
- a new context
-