Class ShortRollingMinMaxOperator.Context
java.lang.Object
io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
io.deephaven.engine.table.impl.updateby.internal.BaseShortUpdateByOperator.Context
io.deephaven.engine.table.impl.updateby.rollingminmax.ShortRollingMinMaxOperator.Context
- All Implemented Interfaces:
SafeCloseable
,AutoCloseable
- Enclosing class:
- ShortRollingMinMaxOperator
-
Field Summary
Modifier and TypeFieldDescriptionprotected AggregatingShortRingBuffer
protected boolean
protected ShortChunk<? extends Values>
Fields inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseShortUpdateByOperator.Context
curVal, outputFillContext, outputValues
Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
affectedPosChunk, influencerPosChunk, nullCount
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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) void
writeToOutputChunk
(int outIdx) Write the current value for this row to the output chunkMethods inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseShortUpdateByOperator.Context
accumulateCumulative, accumulateRolling, writeToOutputColumn
Methods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context
isValueValid, setPosChunks
-
Field Details
-
shortInfluencerValuesChunk
-
aggMinMax
-
evaluationNeeded
protected boolean evaluationNeeded
-
-
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
- Overrides:
close
in classBaseShortUpdateByOperator.Context
-
setValueChunks
- Overrides:
setValueChunks
in classBaseShortUpdateByOperator.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
-
writeToOutputChunk
public void writeToOutputChunk(int outIdx) Description copied from class:UpdateByOperator.Context
Write the current value for this row to the output chunk- Overrides:
writeToOutputChunk
in classBaseShortUpdateByOperator.Context
-
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- Overrides:
reset
in classBaseShortUpdateByOperator.Context
-