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

Class BigIntegerEMAOperator

java.lang.Object

io.deephaven.engine.table.impl.updateby.internal.BaseObjectUpdateByOperator<BigDecimal>

io.deephaven.engine.table.impl.updateby.ema.BigNumberEMAOperator<BigInteger>

io.deephaven.engine.table.impl.updateby.ema.BigIntegerEMAOperator

All Implemented Interfaces:

UpdateByOperator

public class BigIntegerEMAOperator
extends BigNumberEMAOperator<BigInteger>

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.updateby.internal.BaseObjectUpdateByOperator

BaseObjectUpdateByOperator.Context

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.UpdateByOperator

UpdateByOperator.UpdateContext

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.updateby.ema.BigNumberEMAOperator

control, timeRecorder, timeScaleUnits, valueSource

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

affectingColumns, bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, pair, singletonVal

Fields inherited from interface io.deephaven.engine.table.impl.UpdateByOperator

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
BigIntegerEMAOperator(MatchPair pair, String[] affectingColumns, OperationControl control, LongRecordingUpdateByOperator timeRecorder, long timeScaleUnits, ColumnSource<BigInteger> valueSource, RowRedirection rowRedirection)	An operator that computes an EMA from an int column using an exponential decay function.

Method Summary

Methods inherited from class io.deephaven.engine.table.impl.updateby.ema.BigNumberEMAOperator

addChunk, doAddChunk, initializeFor, initializeForUpdate, makeUpdateContext, resetForReprocess, resetForReprocess, setBucketCapacity

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

addChunk, anyModified, applyOutputShift, applyShift, canProcessNormalUpdate, finishFor, getAdditionalModifications, getAffectingColumnNames, getInputColumnName, getOutputColumnNames, getOutputColumns, modifyChunk, onBucketsRemoved, removeChunk, reprocessChunk, reprocessChunk, requiresKeys, requiresValues, setChunkSize, startTrackingPrev

Methods inherited from class java.lang.Object

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

Constructor Details

BigIntegerEMAOperator

public BigIntegerEMAOperator(@NotNull
MatchPair pair,
@NotNull
String[] affectingColumns,
@NotNull
OperationControl control,
@Nullable
LongRecordingUpdateByOperator timeRecorder,
long timeScaleUnits,
@NotNull
ColumnSource<BigInteger> valueSource,
@Nullable
RowRedirection rowRedirection)

An operator that computes an EMA from an int column using an exponential decay function.

Parameters:

pair - the MatchPair that defines the input/output for this operation

affectingColumns - the names of the columns that affect this ema

control - defines how to handle null input values.

timeRecorder - an optional recorder for a timestamp column. If this is null, it will be assumed time is measured in integer ticks.

timeScaleUnits - the smoothing window for the EMA. If no timeRecorder is provided, this is measured in ticks, otherwise it is measured in nanoseconds

valueSource - the input column source. Used when determining reset positions for reprocessing