Class BooleanRollingFormulaOperator.Context
java.lang.Object
io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
io.deephaven.engine.table.impl.updateby.rollingformula.BooleanRollingFormulaOperator.Context
- All Implemented Interfaces:
SafeCloseable
,AutoCloseable
- Enclosing class:
- BooleanRollingFormulaOperator
-
Field Summary
Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
affectedPosChunk, influencerPosChunk, nullCount
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
accumulateCumulative
(@NotNull RowSequence inputKeys, @NotNull Chunk<? extends Values>[] valueChunkArr, @Nullable LongChunk<? extends Values> tsChunk, int len) void
accumulateRolling
(@NotNull RowSequence inputKeys, @NotNull Chunk<? extends Values>[] influencerValueChunkArr, @Nullable LongChunk<OrderedRowKeys> affectedPosChunk, @Nullable LongChunk<OrderedRowKeys> influencerPosChunk, @NotNull IntChunk<? extends Values> pushChunk, @NotNull IntChunk<? extends Values> popChunk, int len) void
close()
void
pop
(int count) Remove values from the operators current data set.void
push
(int pos, int count) Add values to the operators current data setvoid
reset()
Reset the operator data values to a known state.void
setValueChunks
(@NotNull Chunk<? extends Values>[] valueChunks) protected void
writeToOutputChunk
(int outIdx) Write the current value for this row to the output chunkvoid
writeToOutputColumn
(@NotNull RowSequence inputKeys) Write the output chunk to the output columnMethods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
isValueValid, setPosChunks
-
Field Details
-
outputFillContext
-
-
Constructor Details
-
Context
protected Context(int affectedChunkSize, int influencerChunkSize)
-
-
Method Details
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceSafeCloseable
-
setValueChunks
- Specified by:
setValueChunks
in classUpdateByOperator.Context
-
accumulateRolling
public void accumulateRolling(@NotNull @NotNull RowSequence inputKeys, @NotNull @NotNull Chunk<? extends Values>[] influencerValueChunkArr, @Nullable @Nullable LongChunk<OrderedRowKeys> affectedPosChunk, @Nullable @Nullable LongChunk<OrderedRowKeys> influencerPosChunk, @NotNull @NotNull IntChunk<? extends Values> pushChunk, @NotNull @NotNull IntChunk<? extends Values> popChunk, int len) - Specified by:
accumulateRolling
in classUpdateByOperator.Context
-
push
public void push(int pos, int count) Description copied from class:UpdateByOperator.Context
Add values to the operators current data set- Specified by:
push
in classUpdateByOperator.Context
- Parameters:
pos
- the index in the associated chunk where this value can be found. Depending on the usage, might be a values chunk (for cumulative operators) or an influencer values chunk (for windowed). It is the task of the operator to pull the data from the chunk and use it properlycount
- the number of items to push from the chunk
-
pop
public void pop(int count) Description copied from class:UpdateByOperator.Context
Remove values from the operators current data set. This is only valid for windowed operators as cumulative operators only append values- Overrides:
pop
in classUpdateByOperator.Context
- Parameters:
count
- the number of items to pop from the data set
-
reset
public void reset()Description copied from class:UpdateByOperator.Context
Reset the operator data values to a known state. This may occur during initialization or when a windowed operator has an empty window -
accumulateCumulative
public void accumulateCumulative(@NotNull @NotNull RowSequence inputKeys, @NotNull @NotNull Chunk<? extends Values>[] valueChunkArr, @Nullable @Nullable LongChunk<? extends Values> tsChunk, int len) - Specified by:
accumulateCumulative
in classUpdateByOperator.Context
-
writeToOutputChunk
protected void writeToOutputChunk(int outIdx) Description copied from class:UpdateByOperator.Context
Write the current value for this row to the output chunk- Specified by:
writeToOutputChunk
in classUpdateByOperator.Context
-
writeToOutputColumn
Description copied from class:UpdateByOperator.Context
Write the output chunk to the output column- Specified by:
writeToOutputColumn
in classUpdateByOperator.Context
-