From 3362b93ffad0ad67b25eac51ec08b4b3140a9a1d Mon Sep 17 00:00:00 2001 From: yejunhao <41894543+leaves12138@users.noreply.github.com> Date: Thu, 18 Jul 2024 10:36:09 +0800 Subject: [PATCH] fix comment --- .../paimon/mergetree/compact/aggregate/FieldAggregator.java | 4 ++-- .../paimon/mergetree/compact/aggregate/FieldCollectAgg.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java index 67353a161dd2..334a09698a37 100644 --- a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java +++ b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldAggregator.java @@ -173,8 +173,8 @@ private static FieldAggregator createFieldNestedUpdateAgg( public abstract Object agg(Object accumulator, Object inputField); // for sequence group accumulate - public Object aggReversed(Object accumulator, Object inputField) { - return agg(accumulator, inputField); + public Object aggReversed(Object inputField, Object accumulator) { + return agg(inputField, accumulator); } /** reset the aggregator to a clean start state. */ diff --git a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java index 196d6a97a01b..11d40dd67083 100644 --- a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java +++ b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/aggregate/FieldCollectAgg.java @@ -88,9 +88,9 @@ String name() { } @Override - public Object aggReversed(Object accumulator, Object inputField) { + public Object aggReversed(Object inputField, Object accumulator) { // reverse back for this agg - return agg(inputField, accumulator); + return agg(accumulator, inputField); } @Override