Skip to main content
Version: Java (Groovy)

AggPartition

AggPartition returns an aggregator that creates a partition (subtable) for an aggregation group.

Syntax​

AggPartition(resultColumn)
AggPartition(resultColumn, includeGroupByColumns)

Parameters​

ParameterTypeDescription
resultColumnString

The column to create partitions from.

includeGroupByColumnsboolean

Whether to include the group by columns in the result; the default value is true.

Returns​

An aggregator that computes a partition aggregation.

Examples​

In this example, AggPartition returns a partition of the X column, as grouped by Letter. The result table contains two rows: one for each letter. The subtables can be extracted from result.

import static io.deephaven.api.agg.Aggregation.AggPartition

source = emptyTable(20).update("X = i", "Letter = (X % 2 == 0) ? `A` : `B`")

result = source.aggBy([AggPartition("X")], "Letter")

columnSource = result.getColumnSource("X")

resultA = columnSource.get(0)
resultB = columnSource.get(1)