This is an automated email from the ASF dual-hosted git repository.
JingsongLi 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 5872ce7782 [core] Keep one constructor to RowDataFileWriter
5872ce7782 is described below
commit 5872ce7782c14a116bd0141181362aeddc9c0c1e
Author: JingsongLi <[email protected]>
AuthorDate: Fri Aug 7 22:36:20 2026 +0800
[core] Keep one constructor to RowDataFileWriter
---
.../append/DedicatedFormatRollingFileWriter.java | 8 ++++--
.../paimon/append/MultipleBlobFileWriter.java | 4 ++-
.../DataEvolutionBlobCompactTask.java | 4 ++-
.../org/apache/paimon/io/RowDataFileWriter.java | 30 ----------------------
.../apache/paimon/io/RollingFileWriterTest.java | 2 ++
5 files changed, 14 insertions(+), 34 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/append/DedicatedFormatRollingFileWriter.java
b/paimon-core/src/main/java/org/apache/paimon/append/DedicatedFormatRollingFileWriter.java
index 3cf08fc263..19c5875fd4 100644
---
a/paimon-core/src/main/java/org/apache/paimon/append/DedicatedFormatRollingFileWriter.java
+++
b/paimon-core/src/main/java/org/apache/paimon/append/DedicatedFormatRollingFileWriter.java
@@ -281,7 +281,9 @@ public class DedicatedFormatRollingFileWriter
asyncFileWrite,
statsDenseStore,
pathFactory.isExternalPath(),
- normalColumnNames);
+ normalColumnNames,
+ null,
+ null);
return new ProjectedFileWriter<>(rowDataFileWriter,
projectionNormalFields);
};
}
@@ -326,7 +328,9 @@ public class DedicatedFormatRollingFileWriter
asyncFileWrite,
statsDenseStore,
pathFactory.isExternalPath(),
- vectorStoreColumnNames),
+ vectorStoreColumnNames,
+ null,
+ null),
targetFileSize,
Long.MAX_VALUE),
vectorStoreProjection);
diff --git
a/paimon-core/src/main/java/org/apache/paimon/append/MultipleBlobFileWriter.java
b/paimon-core/src/main/java/org/apache/paimon/append/MultipleBlobFileWriter.java
index 7a0901a75f..27f40f2ecd 100644
---
a/paimon-core/src/main/java/org/apache/paimon/append/MultipleBlobFileWriter.java
+++
b/paimon-core/src/main/java/org/apache/paimon/append/MultipleBlobFileWriter.java
@@ -99,7 +99,9 @@ public class MultipleBlobFileWriter implements Closeable {
asyncFileWrite,
statsDenseStore,
pathFactory.isExternalPath(),
- singletonList(blobFieldName)),
+ singletonList(blobFieldName),
+ null,
+ null),
targetFileSize,
writeSchema.projectIndexes(singletonList(blobFieldName))));
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionBlobCompactTask.java
b/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionBlobCompactTask.java
index 675aaf29b9..9056c7b830 100644
---
a/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionBlobCompactTask.java
+++
b/paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionBlobCompactTask.java
@@ -145,7 +145,9 @@ public class DataEvolutionBlobCompactTask extends
DataEvolutionCompactTask {
false,
options.statsDenseStore(),
pathFactory.isExternalPath(),
- Collections.singletonList(blobFieldName));
+ Collections.singletonList(blobFieldName),
+ null,
+ null);
}
private DataField blobField(
diff --git
a/paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java
b/paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java
index 02dff0fd82..361a90facf 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/RowDataFileWriter.java
@@ -57,36 +57,6 @@ public class RowDataFileWriter extends
StatsCollectingSingleFileWriter<InternalR
@Nullable private final List<String> writeCols;
private final RowDataFileSequenceNumberTracker sequenceNumberTracker;
- public RowDataFileWriter(
- FileIO fileIO,
- FileWriterContext context,
- Path path,
- RowType writeSchema,
- long schemaId,
- Supplier<LongCounter> seqNumCounterSupplier,
- FileIndexOptions fileIndexOptions,
- FileSource fileSource,
- boolean asyncFileWrite,
- boolean statsDenseStore,
- boolean isExternalPath,
- @Nullable List<String> writeCols) {
- this(
- fileIO,
- context,
- path,
- writeSchema,
- schemaId,
- seqNumCounterSupplier,
- fileIndexOptions,
- fileSource,
- asyncFileWrite,
- statsDenseStore,
- isExternalPath,
- writeCols,
- null,
- null);
- }
-
public RowDataFileWriter(
FileIO fileIO,
FileWriterContext context,
diff --git
a/paimon-core/src/test/java/org/apache/paimon/io/RollingFileWriterTest.java
b/paimon-core/src/test/java/org/apache/paimon/io/RollingFileWriterTest.java
index bbfb221fbe..ac1c9442e2 100644
--- a/paimon-core/src/test/java/org/apache/paimon/io/RollingFileWriterTest.java
+++ b/paimon-core/src/test/java/org/apache/paimon/io/RollingFileWriterTest.java
@@ -113,6 +113,8 @@ public class RollingFileWriterTest {
true,
statsDenseStore,
false,
+ null,
+ null,
null),
targetFileSize,
targetFileRowNum);
