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

Class RollingGroupOperator.Context

java.lang.Object

io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context

io.deephaven.engine.table.impl.updateby.rollinggroup.RollingGroupOperator.Context

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

RollingGroupOperator

public class RollingGroupOperator.Context
extends UpdateByOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
final ChunkSink.FillFromContext	endSourceFillFromContext
final WritableLongChunk<Values>	endSourceOutputValues
final ChunkSink.FillFromContext	groupRowSetSourceFillFromContext
final WritableObjectChunk<RowSet,? extends Values>	groupRowSetSourceOutputValues
final ChunkSink.FillFromContext	startSourceFillFromContext
final WritableLongChunk<Values>	startSourceOutputValues

Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context

affectedPosChunk, influencerPosChunk, nullCount

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Context(int chunkSize)

Method Summary

Modifier and Type	Method	Description
void	accumulateCumulative(@NotNull RowSequence inputKeys, Chunk<? extends Values>[] valueChunkArr, LongChunk<? extends Values> tsChunk, int len)
void	accumulateRolling(@NotNull RowSequence inputKeys, Chunk<? extends Values>[] influencerValueChunkArr, LongChunk<OrderedRowKeys> affectedPosChunk, LongChunk<OrderedRowKeys> influencerPosChunk, IntChunk<? extends Values> pushChunk, 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 set
void	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 chunk
void	writeToOutputColumn(@NotNull RowSequence inputKeys)	Write the output chunk to the output column

Methods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator.Context

isValueValid, setPosChunks

Methods inherited from class java.lang.Object

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

Field Details

groupRowSetSourceFillFromContext

public final ChunkSink.FillFromContext groupRowSetSourceFillFromContext

groupRowSetSourceOutputValues

public final WritableObjectChunk<RowSet,? extends Values> groupRowSetSourceOutputValues

startSourceFillFromContext

public final ChunkSink.FillFromContext startSourceFillFromContext

startSourceOutputValues

public final WritableLongChunk<Values> startSourceOutputValues

endSourceFillFromContext

public final ChunkSink.FillFromContext endSourceFillFromContext

endSourceOutputValues

public final WritableLongChunk<Values> endSourceOutputValues

Constructor Details

Context

protected Context(int chunkSize)

Method Details

close

public void close()

accumulateCumulative

public void accumulateCumulative(@NotNull
 @NotNull RowSequence inputKeys,
 Chunk<? extends Values>[] valueChunkArr,
 LongChunk<? extends Values> tsChunk,
 int len)

Specified by:

accumulateCumulative in class UpdateByOperator.Context

accumulateRolling

public void accumulateRolling(@NotNull
 @NotNull RowSequence inputKeys,
 Chunk<? extends Values>[] influencerValueChunkArr,
 LongChunk<OrderedRowKeys> affectedPosChunk,
 LongChunk<OrderedRowKeys> influencerPosChunk,
 IntChunk<? extends Values> pushChunk,
 IntChunk<? extends Values> popChunk,
 int len)

Specified by:

accumulateRolling in class UpdateByOperator.Context

setValueChunks

public void setValueChunks(@NotNull
 @NotNull Chunk<? extends Values>[] valueChunks)

Specified by:

setValueChunks in class UpdateByOperator.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 class UpdateByOperator.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 properly

count - 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 class UpdateByOperator.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

Specified by:

writeToOutputChunk in class UpdateByOperator.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

Specified by:

reset in class UpdateByOperator.Context

writeToOutputColumn

public void writeToOutputColumn(@NotNull
 @NotNull RowSequence inputKeys)

Description copied from class: UpdateByOperator.Context

Write the output chunk to the output column

Specified by:

writeToOutputColumn in class UpdateByOperator.Context