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)
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, 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)

Overrides:

accumulateCumulative in class BaseDoubleUpdateByOperator.Context

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