This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new a93be1f002 [core] Remove useless KeyValueFileReaderFactoryType
a93be1f002 is described below
commit a93be1f002f427496fee5f064c17c660db4427d3
Author: JingsongLi <[email protected]>
AuthorDate: Thu Dec 18 00:21:33 2025 +0800
[core] Remove useless KeyValueFileReaderFactoryType
---
.../src/main/java/org/apache/paimon/io/ChainReadContext.java | 8 +++-----
.../main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java | 6 ------
2 files changed, 3 insertions(+), 11 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/io/ChainReadContext.java
b/paimon-core/src/main/java/org/apache/paimon/io/ChainReadContext.java
index aab7759f14..ee50e9eb90 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/ChainReadContext.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/ChainReadContext.java
@@ -25,11 +25,9 @@ import java.util.Map;
/** Information to read the file. */
public class ChainReadContext {
- private BinaryRow logicalPartition;
-
- private Map<String, String> fileBucketPathMapping;
-
- private Map<String, String> fileBranchMapping;
+ private final BinaryRow logicalPartition;
+ private final Map<String, String> fileBucketPathMapping;
+ private final Map<String, String> fileBranchMapping;
private ChainReadContext(
BinaryRow readPartition,
diff --git
a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
index 7f48f24602..91056c588f 100644
---
a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
+++
b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileReaderFactory.java
@@ -167,12 +167,6 @@ public class KeyValueFileReaderFactory implements
FileReaderFactory<KeyValue> {
return new KeyValueDataFileRecordReader(fileRecordReader, keyType,
valueType, file.level());
}
- /** Type of {@link KeyValueFileReaderFactory} to create. */
- public enum KeyValueFileReaderFactoryType {
- DEFAULT,
- CHAIN
- }
-
public static Builder builder(
FileIO fileIO,
SchemaManager schemaManager,