fix comment

apache · Jul 18, 2024 · 3362b93 · 3362b93
1 parent b23686f
commit 3362b93
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -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
@@ -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