Skip to content

Commit 1e37177

Browse files
author
李鹏程
committed
[core] Support remove-record-on-delete for aggregation merge engine
1 parent 5777d6b commit 1e37177

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/AggregateMergeFunction.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -81,16 +81,15 @@ public void reset() {
8181

8282
@Override
8383
public void add(KeyValue kv) {
84+
latestKv = kv;
8485
boolean isRetract =
8586
kv.valueKind() != RowKind.INSERT && kv.valueKind() != RowKind.UPDATE_AFTER;
8687

87-
if (removeRecordOnDelete && isRetract) {
88-
currentDeleteRow = true;
88+
currentDeleteRow = removeRecordOnDelete && isRetract;
89+
if (currentDeleteRow) {
8990
return;
9091
}
9192

92-
latestKv = kv;
93-
9493
for (int i = 0; i < getters.length; i++) {
9594
FieldAggregator fieldAggregator = aggregators[i];
9695
Object accumulator = getters[i].getFieldOrNull(row);

0 commit comments

Comments
 (0)