This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.3 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 21328c6c3d745db9a6b8f63a0a2b4a195c10ab58 Author: JingsongLi <[email protected]> AuthorDate: Wed Sep 17 13:24:25 2025 +0800 [hotfix] Fix comments in MergeFileSplitRead and style --- .../paimon/deletionvectors/DeletionVectorIndexFileWriter.java | 1 - .../main/java/org/apache/paimon/operation/MergeFileSplitRead.java | 8 +++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java b/paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java index 67b9738917..6ce9e1c387 100644 --- a/paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java +++ b/paimon-core/src/main/java/org/apache/paimon/deletionvectors/DeletionVectorIndexFileWriter.java @@ -52,7 +52,6 @@ public class DeletionVectorIndexFileWriter { * <p>TODO: We can consider sending a message to delete the deletion file in the future. */ public IndexFileMeta writeSingleFile(Map<String, DeletionVector> input) throws IOException { - DeletionFileWriter writer = new DeletionFileWriter(indexPathFactory, fileIO); try { for (Map.Entry<String, DeletionVector> entry : input.entrySet()) { diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java b/paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java index 3da14ae7dd..563c3b57be 100644 --- a/paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java +++ b/paimon-core/src/main/java/org/apache/paimon/operation/MergeFileSplitRead.java @@ -20,6 +20,7 @@ package org.apache.paimon.operation; import org.apache.paimon.CoreOptions; import org.apache.paimon.KeyValue; +import org.apache.paimon.KeyValueFileStore; import org.apache.paimon.data.BinaryRow; import org.apache.paimon.data.InternalRow; import org.apache.paimon.deletionvectors.DeletionVector; @@ -64,7 +65,12 @@ import java.util.stream.Collectors; import static org.apache.paimon.predicate.PredicateBuilder.containsFields; import static org.apache.paimon.predicate.PredicateBuilder.splitAnd; -/** A {@link SplitRead} to read row tracking table which need field merge. */ +/** + * An implementation for {@link KeyValueFileStore}, this class handle LSM merging and changelog row + * kind things, it will force reading fields such as sequence and row_kind. + * + * @see RawFileSplitRead If in batch mode and reading raw files, it is recommended to use this read. + */ public class MergeFileSplitRead implements SplitRead<KeyValue> { private final TableSchema tableSchema;
