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

Class BigDecimalEMAOperator

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator<BigDecimal>

com.illumon.iris.db.v2.updateby.ema.BigNumberEMAOperator<BigDecimal>

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

All Implemented Interfaces:

UpdateByOperator

public class BigDecimalEMAOperator
extends BigNumberEMAOperator<BigDecimal>

Nested Class Summary

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

BaseObjectUpdateByOperator.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.BigNumberEMAOperator

control, timeRecorder, timeScaleUnits, valueSource

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

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

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

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

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

Method Summary

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

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

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

BigDecimalEMAOperator

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

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

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