public class SnapshotDeletion extends FileDeletionBase<Snapshot>
changelogDecoupled, deletionBuckets, fileIO, indexFileHandler, manifestFile, manifestList, pathFactory, statsFileHandler
Constructor and Description |
---|
SnapshotDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean produceChangelog,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUnusedDataFiles(Snapshot snapshot,
java.util.function.Predicate<ManifestEntry> skipper)
Clean data files that will not be used anymore in the snapshot.
|
void |
cleanUnusedManifests(Snapshot snapshot,
Set<String> skippingSet)
Clean metadata files that will not be used anymore of a snapshot, including data manifests,
index manifests and manifest lists.
|
addMergedDataFiles, cleanEmptyDirectories, cleanUnusedDataFiles, cleanUnusedIndexManifests, cleanUnusedManifestList, cleanUnusedManifests, cleanUnusedStatisticsManifests, containsDataFile, createDataFileSkipperForTags, deleteAddedDataFiles, deleteFiles, doCleanUnusedDataFile, getDataFileToDelete, manifestSkippingSet, manifestSkippingSet, readManifestFileNames, readMergedDataFiles, recordDeletionBuckets, setChangelogDecoupled, tryReadDataManifests, tryReadManifestList
public SnapshotDeletion(FileIO fileIO, FileStorePathFactory pathFactory, ManifestFile manifestFile, ManifestList manifestList, IndexFileHandler indexFileHandler, StatsFileHandler statsFileHandler, boolean produceChangelog, boolean cleanEmptyDirectories, int deleteFileThreadNum)
public void cleanUnusedDataFiles(Snapshot snapshot, java.util.function.Predicate<ManifestEntry> skipper)
FileDeletionBase
cleanUnusedDataFiles
in class FileDeletionBase<Snapshot>
snapshot
- Snapshot
that will be cleanedskipper
- if the test result of a data file is true, it will be skipped when deleting;
else it will be deletedpublic void cleanUnusedManifests(Snapshot snapshot, Set<String> skippingSet)
FileDeletionBase
cleanUnusedManifests
in class FileDeletionBase<Snapshot>
snapshot
- Snapshot
that will be cleanedskippingSet
- manifests that should not be deletedCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.