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

Class FloatEMAOperator

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.FloatEMAOperator

All Implemented Interfaces:

UpdateByOperator

public class FloatEMAOperator
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
FloatEMAOperator(MatchPair pair, String[] affectingColumns, EmaControl control, LongRecordingUpdateByOperator timeRecorder, long timeScaleUnits, ColumnSource<Float> valueSource, RedirectionIndex redirectionIndex)	An operator that computes an EMA from a float 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

FloatEMAOperator

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

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