From 24263a1d9d587c45fba8292e724e81b688657347 Mon Sep 17 00:00:00 2001 From: LinMingQiang Date: Sun, 28 Jul 2024 13:12:35 +0800 Subject: [PATCH] [core] modify comment. --- .../java/org/apache/paimon/operation/FileDeletionBase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java b/paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java index 1a93dc7d0787..978735babc33 100644 --- a/paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java +++ b/paimon-core/src/main/java/org/apache/paimon/operation/FileDeletionBase.java @@ -77,10 +77,10 @@ public abstract class FileDeletionBase { protected boolean changelogDecoupled; - /** Used to record which tag is cached. */ + /** Used to record which snapshot is cached. */ private long cachedSnapshotId = 0; - /** Used to cache data files used by current tag. */ + /** Used to cache data files used by current snapshot. */ private final Map>> cachedSnapshotDataFiles = new HashMap<>(); @@ -331,7 +331,7 @@ protected void cleanUnusedManifests( public Predicate dataFileSkipper( List skippingSnapshots, long expiringSnapshotId) throws Exception { int index = SnapshotManager.findPreviousSnapshot(skippingSnapshots, expiringSnapshotId); - // refresh tag data files + // refresh snapshot data files if (index >= 0) { Snapshot previousSnapshot = skippingSnapshots.get(index); if (previousSnapshot.id() != cachedSnapshotId) {