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

Class CountWhereOperator

java.lang.Object

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

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

io.deephaven.engine.table.impl.updateby.countwhere.CountWhereOperator

public class CountWhereOperator
extends BaseLongUpdateByOperator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CountWhereOperator.CountFilter	Holder class to hold filter objects and the input column indices they apply to.

Field Summary

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

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
CountWhereOperator(@NotNull MatchPair pair, @NotNull String[] affectingColumns, @Nullable String timestampColumnName, long reverseWindowScaleUnits, long forwardWindowScaleUnits, CountWhereOperator.CountFilter[] filters, String[] inputColumnNames, ColumnSource<?>[] originalSources, ColumnSource<?>[] reinterpretedSources, boolean chunkSourceTableRequired, boolean originalChunksRequired)	Create a new CountWhereOperator for rolling / windowed operations.
CountWhereOperator(@NotNull MatchPair pair, CountWhereOperator.CountFilter[] filters, String[] inputColumnNames, ColumnSource<?>[] originalSources, ColumnSource<?>[] reinterpretedSources, boolean chunkSourceTableRequired, boolean originalChunksRequired)	Create a new CountWhereOperator for cumulative operations.

Method Summary

Modifier and Type	Method	Description
UpdateByOperator	copy()	Create an uninitialized copy of this operator.
protected @NotNull String[]	getInputColumnNames()	This must be overridden to provide the input column chunks that will be needed for computation.
@NotNull 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.BaseLongUpdateByOperator

applyOutputShift, clearOutputRows, getOutputColumns, initializeCumulative, initializeSources, 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

Constructor Details

CountWhereOperator

public CountWhereOperator(@NotNull
 @NotNull MatchPair pair,
 @NotNull
 @NotNull String[] affectingColumns,
 @Nullable
 @Nullable String timestampColumnName,
 long reverseWindowScaleUnits,
 long forwardWindowScaleUnits,
 CountWhereOperator.CountFilter[] filters,
 String[] inputColumnNames,
 ColumnSource<?>[] originalSources,
 ColumnSource<?>[] reinterpretedSources,
 boolean chunkSourceTableRequired,
 boolean originalChunksRequired)

Create a new CountWhereOperator for rolling / windowed operations.

Parameters:

pair - Contains the output column name as a MatchPair

affectingColumns - The names of the columns that when changed would affect this formula output

timestampColumnName - The name of the column containing timestamps for time-based calculations (or null when not time-based)

reverseWindowScaleUnits - The size of the reverse window in ticks (or nanoseconds when time-based)

forwardWindowScaleUnits - The size of the forward window in ticks (or nanoseconds when time-based)

filters - the filters to apply to the input columns

inputColumnNames - The names of the key columns to be used as inputs

originalSources - Representative original sources for the input columns; stores type information and helps convert input data chunks but does not hold any actual data

reinterpretedSources - Representative reinterpreted sources for input columns; stores type information but does not hold any actual data

chunkSourceTableRequired - Whether we need to create and maintain a chunk source table

originalChunksRequired - Whether we need to produce original-typed chunks for condition and chunk filters

CountWhereOperator

public CountWhereOperator(@NotNull
 @NotNull MatchPair pair,
 CountWhereOperator.CountFilter[] filters,
 String[] inputColumnNames,
 ColumnSource<?>[] originalSources,
 ColumnSource<?>[] reinterpretedSources,
 boolean chunkSourceTableRequired,
 boolean originalChunksRequired)

Create a new CountWhereOperator for cumulative operations.

Parameters:

pair - Contains the output column name as a MatchPair

filters - the filters to apply to the input columns

originalSources - Representative original sources for the input columns; stores type information and helps convert input data chunks but does not hold any actual data

reinterpretedSources - Representative reinterpreted sources for input columns; stores type information but does not hold any actual data

chunkSourceTableRequired - Whether we need to create and maintain a chunk source table

originalChunksRequired - Whether we need to produce original-typed chunks for condition and chunk filters

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

getInputColumnNames

@NotNull
protected @NotNull String[] getInputColumnNames()

This must be overridden to provide the input column chunks that will be needed for computation.

Overrides:

getInputColumnNames in class UpdateByOperator

Returns:

the names of the input column

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