comment

apache · Dec 10, 2024 · d07a2c8 · d07a2c8
1 parent 742d478
commit d07a2c8
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java b/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java
@@ -87,15 +87,15 @@ public ColumnarRowIterator copy(ColumnVector[] vectors) {
     }
 
     public ColumnarRowIterator mapping(
-            @Nullable PartitionInfo partitionInfo, @Nullable int[] columnMapping) {
-        if (partitionInfo != null || columnMapping != null) {
+            @Nullable PartitionInfo partitionInfo, @Nullable int[] indexMapping) {
+        if (partitionInfo != null || indexMapping != null) {
             VectorizedColumnBatch vectorizedColumnBatch = row.batch();
             ColumnVector[] vectors = vectorizedColumnBatch.columns;
             if (partitionInfo != null) {
                 vectors = VectorMappingUtils.createPartitionMappedVectors(partitionInfo, vectors);
             }
-            if (columnMapping != null) {
-                vectors = VectorMappingUtils.createMappedVectors(columnMapping, vectors);
+            if (indexMapping != null) {
+                vectors = VectorMappingUtils.createMappedVectors(indexMapping, vectors);
             }
             return copy(vectors);
         }