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

Class BaseObjectUpdateByOperator<T>

java.lang.Object

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

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

Direct Known Subclasses:

BaseBigNumberEMOperator, BaseBigNumberEmStdOperator, BaseObjectBinaryOperator, BigDecimalCumProdOperator, BigDecimalCumSumOperator, BigDecimalDeltaOperator, BigDecimalRollingAvgOperator, BigDecimalRollingProductOperator, BigDecimalRollingStdOperator, BigDecimalRollingSumOperator, BigDecimalRollingWAvgOperator, BigIntegerCumProdOperator, BigIntegerCumSumOperator, BigIntegerDeltaOperator, BigIntegerRollingAvgOperator, BigIntegerRollingProductOperator, BigIntegerRollingStdOperator, BigIntegerRollingSumOperator, ComparableRollingMinMaxOperator, ObjectFillByOperator

public abstract class BaseObjectUpdateByOperator<T>
extends UpdateByOperator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BaseObjectUpdateByOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected final Class<T>	colType
protected WritableColumnSource<T>	maybeInnerSource
protected WritableColumnSource<T>	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
BaseObjectUpdateByOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @Nullable String timestampColumnName, long reverseWindowScaleUnits, long forwardWindowScaleUnits, boolean isWindowed, Class<T> colType)	Construct a base operator for operations that produce Object outputs.
BaseObjectUpdateByOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, Class<T> colType)	Construct a base operator for operations that produce Object outputs.

Method Summary

Modifier and Type	Method	Description
void	applyOutputShift(@NotNull RowSet subRowSetToShift, long delta)	Apply a shift to the operation.
void	clearOutputRows(RowSet toClear)	Clear the output rows by setting value to NULL.
@NotNull Map<String,ColumnSource<?>>	getOutputColumns()	Get a map of outputName to output ColumnSource for this operation.
void	initializeCumulative(UpdateByOperator.Context context, long firstUnmodifiedKey, long firstUnmodifiedTimestamp, @NotNull RowSet bucketRowSet)	Initialize the bucket context for a cumulative operator
void	initializeSources(@NotNull Table source, @Nullable RowRedirection rowRedirection)	Initialize this operator with a specific source table (and row redirection if needed).
void	prepareForParallelPopulation(RowSet changedRows)	Prepare this operator output column for parallel updated.
void	startTrackingPrev()	Indicate that the operation should start tracking previous values for ticking updates.

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

copy, createInputModifiedColumnSet, createOutputModifiedColumnSet, extractDownstreamModifiedColumnSet, finishUpdate, getAffectingColumnNames, getFwdWindowUnits, getInputColumnNames, getInputModifiedColumnSet, getOutputColumnNames, getOutputModifiedColumnSet, getPrevWindowUnits, getTimestampColumnName, initializeRolling, makeUpdateContext, requiresRowPositions

Methods inherited from class java.lang.Object

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

Field Details

outputSource

protected WritableColumnSource<T> outputSource

maybeInnerSource

protected WritableColumnSource<T> maybeInnerSource

colType

protected final Class<T> colType

Constructor Details

BaseObjectUpdateByOperator

public BaseObjectUpdateByOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 Class<T> colType)

Construct a base operator for operations that produce Object outputs.

Parameters:

pair - the MatchPair that defines the input/output for this operation

affectingColumns - a list of all columns (including the input column from the pair) that affects the result of this operator.

BaseObjectUpdateByOperator

public BaseObjectUpdateByOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @Nullable
 @Nullable String timestampColumnName,
 long reverseWindowScaleUnits,
 long forwardWindowScaleUnits,
 boolean isWindowed,
 Class<T> colType)

Construct a base operator for operations that produce Object outputs.

Parameters:

pair - the MatchPair that defines the input/output for this operation

affectingColumns - a list of all columns (including the input column from the pair) that affects the result of this operator.

timestampColumnName - an optional timestamp column. If this is null, it will be assumed time is measured in integer ticks.

reverseWindowScaleUnits - the reverse window for the operator. If no timestampColumnName is provided, this is measured in ticks, otherwise it is measured in nanoseconds.

forwardWindowScaleUnits - the forward window for the operator. If no timestampColumnName is provided, this is measured in ticks, otherwise it is measured in nanoseconds.

Method Details

initializeSources

@OverridingMethodsMustInvokeSuper
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.

Specified by:

initializeSources in class UpdateByOperator

initializeCumulative

public void initializeCumulative(@NotNull
 UpdateByOperator.Context context,
 long firstUnmodifiedKey,
 long firstUnmodifiedTimestamp,
 @NotNull
 @NotNull RowSet bucketRowSet)

Description copied from class: UpdateByOperator

Initialize the bucket context for a cumulative operator

Overrides:

initializeCumulative in class UpdateByOperator

startTrackingPrev

public void startTrackingPrev()

Description copied from class: UpdateByOperator

Indicate that the operation should start tracking previous values for ticking updates.

Specified by:

startTrackingPrev in class UpdateByOperator

applyOutputShift

public void applyOutputShift(@NotNull
 @NotNull RowSet subRowSetToShift,
 long delta)

Description copied from class: UpdateByOperator

Apply a shift to the operation.

Specified by:

applyOutputShift in class UpdateByOperator

prepareForParallelPopulation

public void prepareForParallelPopulation(RowSet changedRows)

Description copied from class: UpdateByOperator

Prepare this operator output column for parallel updated.

Specified by:

prepareForParallelPopulation in class UpdateByOperator

getOutputColumns

@NotNull
public @NotNull Map<String,ColumnSource<?>> getOutputColumns()

Description copied from class: UpdateByOperator

Get a map of outputName to output ColumnSource for this operation.

Specified by:

getOutputColumns in class UpdateByOperator

Returns:

a map of output column name to output column source

clearOutputRows

public void clearOutputRows(RowSet toClear)

Description copied from class: UpdateByOperator

Clear the output rows by setting value to NULL. Dense sources will apply removes to the inner source.

Specified by:

clearOutputRows in class UpdateByOperator