Class | Description |
---|---|
AggregateMergeFunction |
A
MergeFunction where key is primary key (unique) and value is the partial record,
pre-aggregate non-null fields on merge. |
AggregateMergeFunction.RowAggregator |
Provide an Aggregator for merge a new row data.
|
FieldAggregator |
abstract class of aggregating a field of a row.
|
FieldBoolAndAgg |
bool_and aggregate a field of a row.
|
FieldBoolOrAgg |
bool_or aggregate a field of a row.
|
FieldIgnoreRetractAgg |
An aggregator which ignores retraction messages.
|
FieldLastNonNullValueAgg |
last non-null value aggregate a field of a row.
|
FieldLastValueAgg |
last value aggregate a field of a row.
|
FieldListaggAgg |
listagg aggregate a field of a row.
|
FieldMaxAgg |
max aggregate a field of a row.
|
FieldMinAgg |
min aggregate a field of a row.
|
FieldPrimaryKeyAgg |
primary key aggregate a field of a row.
|
FieldSumAgg |
sum aggregate a field of a row.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.