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

Class IntEmStdOperator.Context

java.lang.Object

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

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

io.deephaven.engine.table.impl.updateby.emstd.BasePrimitiveEmStdOperator.Context

io.deephaven.engine.table.impl.updateby.emstd.IntEmStdOperator.Context

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

IntEmStdOperator

protected class IntEmStdOperator.Context
extends BasePrimitiveEmStdOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
IntChunk<? extends Values>	intValueChunk

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

alpha, curEma, curVariance, emaFillContext, emaValues, lastDt, lastStamp, oneMinusAlpha

Fields inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseDoubleUpdateByOperator.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 affectedChunkSize, int influencerChunkSize)

Method Summary

Modifier and Type	Method	Description
void	accumulateCumulative(@NotNull RowSequence inputKeys, 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.
boolean	isValueValid(long atKey)
void	setValueChunks(@NotNull Chunk<? extends Values>[] valuesChunks)
void	writeToOutputColumn(@NotNull RowSequence inputKeys)	Write the output chunk to the output column

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

close, push, reset

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

accumulateRolling, writeNullToOutputChunk, writeToOutputChunk

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

Field Details

intValueChunk

public IntChunk<? extends Values> intValueChunk

Constructor Details

Context

protected Context(int affectedChunkSize,
 int influencerChunkSize)

Method Details

accumulateCumulative

public void accumulateCumulative(@NotNull
 @NotNull RowSequence inputKeys,
 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 BaseDoubleUpdateByOperator.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

writeToOutputColumn

public void writeToOutputColumn(@NotNull
 @NotNull RowSequence inputKeys)

Description copied from class: UpdateByOperator.Context

Write the output chunk to the output column

Overrides:

writeToOutputColumn in class BaseDoubleUpdateByOperator.Context

setValueChunks

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

Overrides:

setValueChunks in class BaseDoubleUpdateByOperator.Context

isValueValid

public boolean isValueValid(long atKey)

Overrides:

isValueValid in class UpdateByOperator.Context