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

Class BigDecimalRollingWAvgOperator<T>

java.lang.Object

io.deephaven.engine.table.impl.updateby.UpdateByOperator

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

io.deephaven.engine.table.impl.updateby.rollingwavg.BigDecimalRollingWAvgOperator<T>

public class BigDecimalRollingWAvgOperator<T>
extends BaseObjectUpdateByOperator<BigDecimal>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BigDecimalRollingWAvgOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected @NotNull ColumnSource<?>	valueColumnSource
protected @NotNull ColumnSource<?>	weightColumnSource

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

colType, maybeInnerSource, outputSource

Fields inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator

affectingColumns, forwardWindowScaleUnits, inputModifiedColumnSet, isWindowed, outputModifiedColumnSet, pair, reverseWindowScaleUnits, rowRedirection, timestampColumnName

Constructor Summary

Constructors

Constructor	Description
BigDecimalRollingWAvgOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @Nullable String timestampColumnName, long reverseWindowScaleUnits, long forwardWindowScaleUnits, @NotNull String weightColumnName, @NotNull MathContext mathContext)

Method Summary

Modifier and Type	Method	Description
UpdateByOperator	copy()	Create an uninitialized copy of this operator.
protected @NotNull String[]	getInputColumnNames()	Get the names of the input column(s) for this operator.
void	initializeSources(@NotNull Table source, @Nullable RowRedirection rowRedirection)	Initialize this operator with a specific source table (and row redirection if needed).
UpdateByOperator.Context	makeUpdateContext(int affectedChunkSize, int influencerChunkSize)	Make an UpdateByOperator.Context suitable for use with updates.

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

applyOutputShift, clearOutputRows, getOutputColumns, initializeCumulative, prepareForParallelPopulation, startTrackingPrev

Methods inherited from class io.deephaven.engine.table.impl.updateby.UpdateByOperator

createInputModifiedColumnSet, createOutputModifiedColumnSet, extractDownstreamModifiedColumnSet, finishUpdate, getAffectingColumnNames, getFwdWindowUnits, getInputModifiedColumnSet, getOutputColumnNames, getOutputModifiedColumnSet, getPrevWindowUnits, getTimestampColumnName, initializeCumulativeWithKeyValues, initializeRolling, initializeRollingWithKeyValues, requiresRowPositions

Methods inherited from class java.lang.Object

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

Field Details

weightColumnSource

@NotNull
protected @NotNull ColumnSource<?> weightColumnSource

valueColumnSource

@NotNull
protected @NotNull ColumnSource<?> valueColumnSource

Constructor Details

BigDecimalRollingWAvgOperator

public BigDecimalRollingWAvgOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @Nullable
 @Nullable String timestampColumnName,
 long reverseWindowScaleUnits,
 long forwardWindowScaleUnits,
 @NotNull
 @NotNull String weightColumnName,
 @NotNull
 @NotNull MathContext mathContext)

Method Details

makeUpdateContext

@NotNull
public UpdateByOperator.Context makeUpdateContext(int affectedChunkSize,
 int influencerChunkSize)

Description copied from class: UpdateByOperator

Make an UpdateByOperator.Context suitable for use with updates.

Specified by:

makeUpdateContext in class UpdateByOperator

Parameters:

affectedChunkSize - The maximum size of affected chunks that will be provided during the update.

influencerChunkSize - The maximum size of influencer chunks that will be provided during the update.

Returns:

a new context

initializeSources

public void initializeSources(@NotNull
 @NotNull Table source,
 @Nullable
 @Nullable RowRedirection rowRedirection)

Description copied from class: UpdateByOperator

Initialize this operator with a specific source table (and row redirection if needed). This will be called exactly once per operator.

Overrides:

initializeSources in class BaseObjectUpdateByOperator<BigDecimal>

copy

public UpdateByOperator copy()

Description copied from class: UpdateByOperator

Create an uninitialized copy of this operator. UpdateByOperator.initializeSources(Table, RowRedirection) must be called before this operator can be used.

Specified by:

copy in class UpdateByOperator

Returns:

a copy of this operator

getInputColumnNames

@NotNull
protected @NotNull String[] getInputColumnNames()

Get the names of the input column(s) for this operator.

Overrides:

getInputColumnNames in class UpdateByOperator

Returns:

the names of the input column