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 2407353a8 [core] Rename to compactDvIndexFiles in FileStoreCommitImpl
2407353a8 is described below
commit 2407353a8a1cb026995080ddd801042b021c9784
Author: Jingsong <[email protected]>
AuthorDate: Thu Mar 28 14:29:25 2024 +0800
[core] Rename to compactDvIndexFiles in FileStoreCommitImpl
---
.../apache/paimon/operation/FileStoreCommitImpl.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 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 d3ce76b0a..5c6343956 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
@@ -221,7 +221,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
List<ManifestEntry> compactTableFiles = new ArrayList<>();
List<ManifestEntry> compactChangelog = new ArrayList<>();
List<IndexManifestEntry> appendHashIndexFiles = new ArrayList<>();
- List<IndexManifestEntry> appendDvIndexFiles = new ArrayList<>();
+ List<IndexManifestEntry> compactDvIndexFiles = new ArrayList<>();
collectChanges(
committable.fileCommittables(),
appendTableFiles,
@@ -229,7 +229,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
compactTableFiles,
compactChangelog,
appendHashIndexFiles,
- appendDvIndexFiles);
+ compactDvIndexFiles);
try {
List<SimpleFileEntry> appendSimpleEntries =
SimpleFileEntry.from(appendTableFiles);
if (!ignoreEmptyCommit
@@ -272,7 +272,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
if (!compactTableFiles.isEmpty()
|| !compactChangelog.isEmpty()
- || !appendDvIndexFiles.isEmpty()) {
+ || !compactDvIndexFiles.isEmpty()) {
// Optimization for common path.
// Step 2:
// Add appendChanges to the manifest entries read above and
check for conflicts.
@@ -294,7 +294,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
tryCommit(
compactTableFiles,
compactChangelog,
- appendDvIndexFiles,
+ compactDvIndexFiles,
committable.identifier(),
committable.watermark(),
committable.logOffsets(),
@@ -360,7 +360,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
List<ManifestEntry> compactTableFiles = new ArrayList<>();
List<ManifestEntry> compactChangelog = new ArrayList<>();
List<IndexManifestEntry> appendHashIndexFiles = new ArrayList<>();
- List<IndexManifestEntry> appendDvIndexFiles = new ArrayList<>();
+ List<IndexManifestEntry> compactDvIndexFiles = new ArrayList<>();
collectChanges(
committable.fileCommittables(),
appendTableFiles,
@@ -368,7 +368,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
compactTableFiles,
compactChangelog,
appendHashIndexFiles,
- appendDvIndexFiles);
+ compactDvIndexFiles);
if (!appendChangelog.isEmpty() || !compactChangelog.isEmpty()) {
StringBuilder warnMessage =
@@ -437,12 +437,12 @@ public class FileStoreCommitImpl implements
FileStoreCommit {
generatedSnapshot += 1;
}
- if (!compactTableFiles.isEmpty() || !appendDvIndexFiles.isEmpty())
{
+ if (!compactTableFiles.isEmpty() ||
!compactDvIndexFiles.isEmpty()) {
attempts +=
tryCommit(
compactTableFiles,
Collections.emptyList(),
- appendDvIndexFiles,
+ compactDvIndexFiles,
committable.identifier(),
committable.watermark(),
committable.logOffsets(),
@@ -565,7 +565,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
List<ManifestEntry> compactTableFiles,
List<ManifestEntry> compactChangelog,
List<IndexManifestEntry> appendHashIndexFiles,
- List<IndexManifestEntry> appendDvIndexFiles) {
+ List<IndexManifestEntry> compactDvIndexFiles) {
for (CommitMessage message : commitMessages) {
CommitMessageImpl commitMessage = (CommitMessageImpl) message;
commitMessage
@@ -606,7 +606,7 @@ public class FileStoreCommitImpl implements FileStoreCommit
{
f));
break;
case DELETION_VECTORS_INDEX:
- appendDvIndexFiles.add(
+ compactDvIndexFiles.add(
new IndexManifestEntry(
FileKind.ADD,
commitMessage.partition(),
