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

Class BigDecimalEMOperator.Context

java.lang.Object

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

BaseObjectUpdateByOperator<BigDecimal>.Context

BaseBigNumberEMOperator<BigDecimal>.Context

io.deephaven.engine.table.impl.updateby.em.BigDecimalEMOperator.Context

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

BigDecimalEMOperator

public class BigDecimalEMOperator.Context
extends BaseBigNumberEMOperator<BigDecimal>.Context

Field Summary

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

alpha, lastDt, lastStamp, objectValueChunk, oneMinusAlpha

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

curVal, outputFillContext, outputValues

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, @NotNull Chunk<? extends Values>[] valueChunkArr, LongChunk<? extends Values> tsChunk, int len)	For cumulative operators only, this method will be called to pass the input chunk data to the operator and produce the output data values.
void	push(int pos, int count)	Add values to the operators current data set

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

isValueValid, reset, setValueChunks

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

accumulateRolling, close, writeNullToOutputChunk, writeToOutputChunk, writeToOutputColumn

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

pop, setPosChunks

Methods inherited from class java.lang.Object

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

Constructor Details

Context

protected Context(int chunkSize)

Method Details

accumulateCumulative

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

Description copied from class: UpdateByOperator.Context

For cumulative operators only, this method will be called to pass the input chunk data to the operator and produce the output data values.

Overrides:

accumulateCumulative in class BaseObjectUpdateByOperator<BigDecimal>.Context

Parameters:

inputKeys - the keys for the input data rows (also matches the output keys)

valueChunkArr - the input data chunks needed by the operator for internal calculations

tsChunk - the timestamp chunk for the input data (if applicable)

len - the number of items in the input data chunks

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