Package io.deephaven.engine.table.impl.by
package io.deephaven.engine.table.impl.by
-
ClassDescriptionComputes the columns to exclude from aggregation outputEncapsulates the operators and inputs for an aggregation operation.Produces an AggregationContext for aggregations given a table and the names of the group by columns.Transformer to adjust aggregation results for operation building.Stateless "control" class for giving external code (e.g.This exception provides more context when an aggregation operator throws an Exception.Conversion tool to generate an
AggregationContextFactoryfor a collection ofaggregations.Tool to identify the aggregation result row key (also row position) from a logical key representing a set of values for the aggregation's group-by columns.Generate approximate percentile aggregations of a table.Base class with shared boilerplate forBlinkFirstChunkedOperatorandBlinkLastChunkedOperator.The output RowSet of an aggregation is fairly special.A firstBy aggregation operator for blink tables.A lastBy aggregation operator for blink tables.Iterative Boolean Sum.Chunked aggregation operator for sorted first/last-by using a byte sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a byte sort-column on blink tables.Iterative sum operator, extended for absolute values and regular sums.Chunked aggregation operator for sorted first/last-by using a char sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a char sort-column on blink tables.Iterative sum operator, extended for absolute values and regular sums.Base-class for stream first/last-by chunked operators that need to copy data from source columns to result columns with a permutation on the redirected indices.Chunked aggregation operator for sorted first/last-by using a double sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a double sort-column on blink tables.Chunked aggregation operator for sorted first/last-by using a float sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a float sort-column on blink tables.AnIterativeChunkedAggregationOperatorused in the implementation ofTableOperations.groupBy(),AggSpecGroup, andAggregation.AggGroup(String...).Finds runs of the same slot, and fills in the chunkPositions, runStarts, and runLengths arrays.Callback from generated hash table code.When building, this operation is never invoked.When probing, these operations are never invoked.HashTableColumnSource<DATA_TYPE>ColumnSourceimplementation that delegates to the main and overflow sources for a hash table column.Interface for ChunkedOperatorAggregationHelper to process incremental updates.Chunked aggregation operator for sorted first/last-by using a int sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a int sort-column on blink tables.Iterative sum operator, extended for absolute values and regular sums.A chunked, iterative operator that processes row keys and/or data from one input column to produce one or more output columns.Context interface for bucketed operator updates.Context interface for singleton (that is, one aggregation state) operator updates.Chunked aggregation operator for sorted first/last-by using a long sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a long sort-column on blink tables.Iterative sum operator, extended for absolute values and regular sums.Chunked aggregation operator for sorted first/last-by using a Object sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a Object sort-column on blink tables.AnIterativeChunkedAggregationOperatorused in the implementation ofTable.partitionBy(boolean, java.lang.String...)andPartition.Implementation constants forTable.rollup(java.util.Collection<? extends io.deephaven.api.agg.Aggregation>)support.Chunked aggregation operator for sorted first/last-by using a short sort-column on add-only tables.Chunked aggregation operator for sorted first/last-by using a short sort-column on blink tables.Iterative sum operator, extended for absolute values and regular sums.Iterative T-Digest and percentile operator.Implementation constants forTable.tree(java.lang.String, java.lang.String)support.