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 09997f288c [core] rename FileStoreCommitImpl var name (#9457)
09997f288c is described below
commit 09997f288cca785f0d9aae4c917c059cf82c5235
Author: weijie <[email protected]>
AuthorDate: Sat Aug 29 20:54:23 2026 +0800
[core] rename FileStoreCommitImpl var name (#9457)
---
.../org/apache/paimon/operation/FileStoreCommitImpl.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
index 2809101551..49a231821c 100644
---
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
+++
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
@@ -1097,7 +1097,7 @@ public class FileStoreCommitImpl implements
FileStoreCommit {
Snapshot newSnapshot;
Pair<String, Long> baseManifestList = null;
Pair<String, Long> deltaManifestList = null;
- List<PartitionEntry> deltaStatistics;
+ List<PartitionEntry> deltaPartitionEntries;
Pair<String, Long> changelogManifestList = null;
String oldIndexManifest = null;
String indexManifest = null;
@@ -1173,7 +1173,7 @@ public class FileStoreCommitImpl implements
FileStoreCommit {
long totalRecordCount = previousTotalRecordCount +
deltaRecordCount;
// write new delta files into manifest files
- deltaStatistics = new
ArrayList<>(PartitionEntry.merge(deltaFiles));
+ deltaPartitionEntries = new
ArrayList<>(PartitionEntry.merge(deltaFiles));
deltaManifestList =
manifestList.write(manifestFile.write(deltaFiles));
// write changelog into manifest files
@@ -1263,7 +1263,7 @@ public class FileStoreCommitImpl implements
FileStoreCommit {
callback ->
callback.call(finalBaseFiles, finalDeltaFiles,
indexFiles, newSnapshot));
try {
- success = commitSnapshotImpl(latestSnapshot, newSnapshot,
deltaStatistics);
+ success = commitSnapshotImpl(latestSnapshot, newSnapshot,
deltaPartitionEntries);
} catch (Exception e) {
// commit exception, not sure about the situation and should not
clean up the files
LOG.warn(
@@ -1666,10 +1666,10 @@ public class FileStoreCommitImpl implements
FileStoreCommit {
private boolean commitSnapshotImpl(
@Nullable Snapshot baseSnapshot,
Snapshot newSnapshot,
- List<PartitionEntry> deltaStatistics) {
+ List<PartitionEntry> deltaPartitionEntries) {
try {
- List<PartitionStatistics> statistics = new
ArrayList<>(deltaStatistics.size());
- for (PartitionEntry entry : deltaStatistics) {
+ List<PartitionStatistics> statistics = new
ArrayList<>(deltaPartitionEntries.size());
+ for (PartitionEntry entry : deltaPartitionEntries) {
statistics.add(entry.toPartitionStatistics(partitionComputer));
}
return snapshotCommit.commit(