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

Class BaseBigNumberEmStdOperator.Context

java.lang.Object

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

BaseObjectUpdateByOperator<BigDecimal>.Context

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

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Direct Known Subclasses:

BigDecimalEmStdOperator.Context, BigIntegerEmStdOperator.Context

Enclosing class:

BaseBigNumberEmStdOperator<T>

public abstract class BaseBigNumberEmStdOperator.Context
extends BaseObjectUpdateByOperator<BigDecimal>.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected BigDecimal	alpha
protected BigDecimal	curEma
protected BigDecimal	curVariance
protected final ChunkSink.FillFromContext	emaFillContext
protected final WritableObjectChunk<BigDecimal,? extends Values>	emaValues
protected long	lastDt
protected long	lastStamp
protected ObjectChunk<T,? extends Values>	objectValueChunk
protected BigDecimal	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	close()
boolean	isValueValid(long atKey)
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	writeToOutputColumn(@NotNull RowSequence inputKeys)	Write the output chunk to the output column

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

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

objectValueChunk

protected ObjectChunk<T,? extends Values> objectValueChunk

emaFillContext

protected final ChunkSink.FillFromContext emaFillContext

emaValues

protected final WritableObjectChunk<BigDecimal,? extends Values> emaValues

alpha

protected BigDecimal alpha

oneMinusAlpha

protected BigDecimal oneMinusAlpha

lastDt

protected long lastDt

lastStamp

protected long lastStamp

curEma

protected BigDecimal curEma

curVariance

protected BigDecimal curVariance

Constructor Details

Context

protected Context(int chunkSize)

Method Details

setValueChunks

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

Overrides:

setValueChunks in class BaseObjectUpdateByOperator<BigDecimal>.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 BaseObjectUpdateByOperator<BigDecimal>.Context

isValueValid

public boolean isValueValid(long atKey)

Overrides:

isValueValid 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

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

Overrides:

reset in class BaseObjectUpdateByOperator<BigDecimal>.Context

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

Overrides:

close in class BaseObjectUpdateByOperator<BigDecimal>.Context