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

Class BaseObjectUpdateByOperator.Context

java.lang.Object

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

io.deephaven.engine.table.impl.updateby.internal.BaseObjectUpdateByOperator.Context

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Direct Known Subclasses:

BaseObjectBinaryOperator.Context, BigDecimalCumProdOperator.Context, BigDecimalCumSumOperator.Context, BigDecimalRollingSumOperator.Context, BigIntegerCumProdOperator.Context, BigIntegerCumSumOperator.Context, BigIntegerRollingSumOperator.Context, BigNumberEMAOperator.Context, ObjectFillByOperator.Context

Enclosing class:

BaseObjectUpdateByOperator<T>

protected abstract class BaseObjectUpdateByOperator.Context
extends UpdateByOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
T	curVal
ChunkSink.FillFromContext	outputFillContext
WritableObjectChunk<T,Values>	outputValues

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

nullCount

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Context(int chunkSize)

Method Summary

Modifier and Type	Method	Description
void	accumulateCumulative(RowSequence inputKeys, Chunk<? extends Values>[] valueChunkArr, LongChunk<? extends Values> tsChunk, int len)
void	accumulateRolling(RowSequence inputKeys, Chunk<? extends Values>[] influencerValueChunkArr, IntChunk<? extends Values> pushChunk, IntChunk<? extends Values> popChunk, int len)
void	close()
void	reset()	Reset the operator data values to a known state.
void	setValuesChunk(Chunk<? extends Values> valuesChunk)
void	writeToOutputChunk(int outIdx)	Write the current value for this row to the output chunk
void	writeToOutputColumn(RowSequence inputKeys)	Write the output chunk to the output column

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

isValueValid, pop, push

Methods inherited from class java.lang.Object

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

Field Details

outputFillContext

public final ChunkSink.FillFromContext outputFillContext

outputValues

public final WritableObjectChunk<T,Values> outputValues

curVal

public T curVal

Constructor Details

Context

protected Context(int chunkSize)

Method Details

accumulateCumulative

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

Specified by:

accumulateCumulative in class UpdateByOperator.Context

accumulateRolling

public void accumulateRolling(RowSequence inputKeys,
Chunk<? extends Values>[] influencerValueChunkArr,
IntChunk<? extends Values> pushChunk,
IntChunk<? extends Values> popChunk,
int len)

Specified by:

accumulateRolling in class UpdateByOperator.Context

setValuesChunk

public void setValuesChunk(@NotNull
Chunk<? extends Values> valuesChunk)

Specified by:

setValuesChunk in class UpdateByOperator.Context

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

writeToOutputColumn

public void writeToOutputColumn(@NotNull
RowSequence inputKeys)

Description copied from class: UpdateByOperator.Context

Write the output chunk to the output column

Specified by:

writeToOutputColumn 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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

Overrides:

close in class UpdateByOperator.Context