You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/08/29 12:54:28 UTC
(paimon) branch master updated: [core] rename FileStoreCommitImpl var name (#9457)
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 <to...@gmail.com>
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(