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

Class LongEMAOperator

java.lang.Object

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

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

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

All Implemented Interfaces:

UpdateByOperator

public class LongEMAOperator
extends BasePrimitiveEMAOperator

Nested Class Summary

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

BaseDoubleUpdateByOperator.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.BasePrimitiveEMAOperator

control, timeRecorder, timeScaleUnits

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

bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, singletonGroup, singletonVal

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

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

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

Method Summary

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

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

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

addChunk, anyModified, applyOutputShift, applyShift, canProcessNormalUpdate, finishFor, getAdditionalModifications, getAffectingColumnNames, getInputColumnName, getOutputColumnNames, getOutputColumns, modifyChunk, 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

LongEMAOperator

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

An operator that computes an EMA from a long 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