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

Class LongRollingFormulaOperator

java.lang.Object

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

io.deephaven.engine.table.impl.updateby.rollingformula.LongRollingFormulaOperator

public class LongRollingFormulaOperator
extends UpdateByOperator

Rolling formula operator for source long columns. The output column type will be entirely dependent on the formula provided by the user.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	LongRollingFormulaOperator.Context

Field Summary

Fields

Modifier and Type	Field	Description
protected WritableColumnSource<?>	maybeInnerSource
protected WritableColumnSource<?>	outputSource
protected final String	PARAM_COLUMN_NAME
protected WritableColumnSource<?>	primitiveOutputSource

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

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

Constructor Summary

Constructors

Modifier	Constructor	Description
	LongRollingFormulaOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @Nullable String timestampColumnName, long reverseWindowScaleUnits, long forwardWindowScaleUnits, @NotNull String formula, @NotNull String paramToken, @NotNull Map<Class<?>,FormulaColumn> formulaColumnMap, @NotNull TableDefinition tableDef, @NotNull QueryCompilerRequestProcessor compilationProcessor)
protected	LongRollingFormulaOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @Nullable String timestampColumnName, long reverseWindowScaleUnits, long forwardWindowScaleUnits, Class<?> vectorType, @NotNull Map<Class<?>,FormulaColumn> formulaColumnMap, @NotNull TableDefinition tableDef)

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.
UpdateByOperator	copy()	Create an uninitialized copy of this operator.
protected static IntConsumer	getChunkSetter(WritableChunk<? extends Values> valueChunk, ColumnSource<?> formulaOutputSource)
@NotNull Map<String,ColumnSource<?>>	getOutputColumns()	Get a map of outputName to output ColumnSource for this operation.
void	initializeSources(@NotNull Table source, @Nullable RowRedirection rowRedirection)	Initialize this operator with a specific source table (and row redirection if needed).
@NotNull UpdateByOperator.Context	makeUpdateContext(int affectedChunkSize, int influencerChunkSize)	Make an UpdateByOperator.Context suitable for use with updates.
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

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

Methods inherited from class java.lang.Object

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

Field Details

PARAM_COLUMN_NAME

protected final String PARAM_COLUMN_NAME

See Also:

• Constant Field Values

primitiveOutputSource

protected WritableColumnSource<?> primitiveOutputSource

outputSource

protected WritableColumnSource<?> outputSource

maybeInnerSource

protected WritableColumnSource<?> maybeInnerSource

Constructor Details

LongRollingFormulaOperator

public LongRollingFormulaOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @Nullable
 @Nullable String timestampColumnName,
 long reverseWindowScaleUnits,
 long forwardWindowScaleUnits,
 @NotNull
 @NotNull String formula,
 @NotNull
 @NotNull String paramToken,
 @NotNull
 @NotNull Map<Class<?>,FormulaColumn> formulaColumnMap,
 @NotNull
 @NotNull TableDefinition tableDef,
 @NotNull
 @NotNull QueryCompilerRequestProcessor compilationProcessor)

LongRollingFormulaOperator

protected LongRollingFormulaOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @Nullable
 @Nullable String timestampColumnName,
 long reverseWindowScaleUnits,
 long forwardWindowScaleUnits,
 Class<?> vectorType,
 @NotNull
 @NotNull Map<Class<?>,FormulaColumn> formulaColumnMap,
 @NotNull
 @NotNull TableDefinition tableDef)

Method Details

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

makeUpdateContext

public @NotNull 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.

Specified by:

initializeSources in class UpdateByOperator

getChunkSetter

protected static IntConsumer getChunkSetter(WritableChunk<? extends Values> valueChunk,
 ColumnSource<?> formulaOutputSource)

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

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

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