Package | Description |
---|---|
org.apache.flink.table.store.file.mergetree.compact.aggregate |
Modifier and Type | Class and Description |
---|---|
class |
FieldBoolAndAgg
bool_and aggregate a field of a row.
|
class |
FieldBoolOrAgg
bool_or aggregate a field of a row.
|
class |
FieldIgnoreRetractAgg
An aggregator which ignores retraction messages.
|
class |
FieldLastNonNullValueAgg
last non-null value aggregate a field of a row.
|
class |
FieldLastValueAgg
last value aggregate a field of a row.
|
class |
FieldListaggAgg
listagg aggregate a field of a row.
|
class |
FieldMaxAgg
max aggregate a field of a row.
|
class |
FieldMinAgg
min aggregate a field of a row.
|
class |
FieldPrimaryKeyAgg
primary key aggregate a field of a row.
|
class |
FieldSumAgg
sum aggregate a field of a row.
|
Modifier and Type | Method and Description |
---|---|
FieldAggregator |
AggregateMergeFunction.RowAggregator.getFieldAggregatorAtPos(int fieldPos) |
Constructor and Description |
---|
FieldIgnoreRetractAgg(FieldAggregator aggregator) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.