Skip to content

Commit

Permalink
[core] modify comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
LinMingQiang committed Jul 28, 2024
1 parent c36e78b commit 24263a1
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -77,10 +77,10 @@ public abstract class FileDeletionBase<T extends Snapshot> {

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<BinaryRow, Map<Integer, Set<String>>> cachedSnapshotDataFiles =
new HashMap<>();

Expand Down Expand Up @@ -331,7 +331,7 @@ protected void cleanUnusedManifests(
public Predicate<ManifestEntry> dataFileSkipper(
List<Snapshot> 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) {
Expand Down

0 comments on commit 24263a1

Please sign in to comment.