Package | Description |
---|---|
org.apache.paimon.mergetree.compact | |
org.apache.paimon.mergetree.compact.aggregate | |
org.apache.paimon.mergetree.compact.aggregate.factory |
Constructor and Description |
---|
PartialUpdateMergeFunction(InternalRow.FieldGetter[] getters,
boolean ignoreDelete,
Map<Integer,FieldsComparator> fieldSeqComparators,
Map<Integer,FieldAggregator> fieldAggregators,
boolean fieldSequenceEnabled,
boolean removeRecordOnDelete,
Set<Integer> sequenceGroupPartialDelete) |
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 |
FieldCollectAgg
Collect elements into an ARRAY.
|
class |
FieldFirstNonNullValueAgg
first non-null value aggregate a field of a row.
|
class |
FieldFirstValueAgg
first value aggregate a field of a row.
|
class |
FieldHllSketchAgg
HllSketch 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 |
FieldMergeMapAgg
Merge two maps.
|
class |
FieldMinAgg
min aggregate a field of a row.
|
class |
FieldNestedUpdateAgg
Used to update a field which representing a nested table.
|
class |
FieldPrimaryKeyAgg
primary key aggregate a field of a row.
|
class |
FieldProductAgg
product value aggregate a field of a row.
|
class |
FieldRoaringBitmap32Agg
roaring bitmap aggregate a field of a row.
|
class |
FieldRoaringBitmap64Agg
roaring bitmap aggregate a field of a row.
|
class |
FieldSumAgg
sum aggregate a field of a row.
|
class |
FieldThetaSketchAgg
ThetaSketch aggregate a field of a row.
|
Constructor and Description |
---|
AggregateMergeFunction(InternalRow.FieldGetter[] getters,
FieldAggregator[] aggregators) |
FieldIgnoreRetractAgg(FieldAggregator aggregator) |
Modifier and Type | Method and Description |
---|---|
FieldAggregator |
FieldFirstNonNullValueAggLegacyFactory.create(DataType fieldType,
CoreOptions options,
String field) |
FieldAggregator |
FieldNestedUpdateAggFactory.create(DataType fieldType,
CoreOptions options,
String field) |
FieldAggregator |
FieldPrimaryKeyAggFactory.create(DataType fieldType,
CoreOptions options,
String field) |
FieldAggregator |
FieldAggregatorFactory.create(DataType fieldType,
CoreOptions options,
String field) |
static FieldAggregator |
FieldAggregatorFactory.create(DataType fieldType,
String strAgg,
boolean ignoreRetract,
boolean isPrimaryKey,
CoreOptions options,
String field) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.