Package com.illumon.iris.db.v2.updateby.ema

Class DoubleEMAOperator

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.BaseDoubleUpdateByOperator

com.illumon.iris.db.v2.updateby.ema.BasePrimitiveEMAOperator

com.illumon.iris.db.v2.updateby.ema.DoubleEMAOperator

All Implemented Interfaces:

UpdateByOperator

public class DoubleEMAOperator
extends BasePrimitiveEMAOperator

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.updateby.internal.BaseDoubleUpdateByOperator

BaseDoubleUpdateByOperator.Context

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

UpdateByOperator.UpdateContext

Field Summary

Fields inherited from class com.illumon.iris.db.v2.updateby.ema.BasePrimitiveEMAOperator

control, timeRecorder, timeScaleUnits

Fields inherited from class com.illumon.iris.db.v2.updateby.internal.BaseDoubleUpdateByOperator

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

Fields inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
DoubleEMAOperator(MatchPair pair, String[] affectingColumns, EmaControl control, LongRecordingUpdateByOperator timeRecorder, long timeScaleUnits, ColumnSource<Double> valueSource, RedirectionIndex redirectionIndex)	An operator that computes an EMA from a double column using an exponential decay function.

Method Summary

Methods inherited from class com.illumon.iris.db.v2.updateby.ema.BasePrimitiveEMAOperator

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

Methods inherited from class com.illumon.iris.db.v2.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

DoubleEMAOperator

public DoubleEMAOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @NotNull EmaControl control, @Nullable LongRecordingUpdateByOperator timeRecorder, long timeScaleUnits, @NotNull ColumnSource<Double> valueSource, @Nullable RedirectionIndex redirectionIndex)

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

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