Package io.deephaven.engine.table.impl.by

Interface GroupByOperator

All Superinterfaces:

IterativeChunkedAggregationOperator

All Known Implementing Classes:

GroupByChunkedOperator, GroupByReaggregateOperator

public interface GroupByOperator
extends IterativeChunkedAggregationOperator

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.by.IterativeChunkedAggregationOperator

IterativeChunkedAggregationOperator.BucketedContext, IterativeChunkedAggregationOperator.SingletonContext

Field Summary

Fields inherited from interface io.deephaven.engine.table.impl.by.IterativeChunkedAggregationOperator

ZERO_LENGTH_ITERATIVE_CHUNKED_AGGREGATION_OPERATOR_ARRAY

Method Summary

Modifier and Type	Method	Description
Map<String,? extends ColumnSource<?>>	getInputResultColumns()	Get a map from input column names to the corresponding output ColumnSource.
boolean	hasModifications(boolean columnsModified)	Determine whether to propagate changes when input columns have been modified.

Methods inherited from interface io.deephaven.engine.table.impl.by.IterativeChunkedAggregationOperator

addChunk, addChunk, addRowSet, ensureCapacity, getResultColumns, initializeRefreshing, makeBucketedContext, makeSingletonContext, modifyChunk, modifyChunk, modifyRowKeys, modifyRowKeys, propagateFailure, propagateInitialState, propagateUpdates, removeChunk, removeChunk, requiresRowKeys, requiresRunFinds, resetForStep, shiftChunk, shiftChunk, startTrackingPrevValues, unchunkedRowSet

Method Details

getInputResultColumns

Map<String,? extends ColumnSource<?>> getInputResultColumns()

Get a map from input column names to the corresponding output ColumnSource.

hasModifications

boolean hasModifications(boolean columnsModified)

Determine whether to propagate changes when input columns have been modified.

Parameters:

columnsModified - have any of the input columns been modified (as per the MCS)?

Returns:

true if we have modified our output (e.g., because of additions or modifications).