Package | Description |
---|---|
org.apache.paimon.manifest | |
org.apache.paimon.operation |
Modifier and Type | Method and Description |
---|---|
ManifestFile |
ManifestFile.Factory.create() |
Modifier and Type | Method and Description |
---|---|
static void |
FileEntry.mergeEntries(ManifestFile manifestFile,
List<ManifestFileMeta> manifestFiles,
Map<FileEntry.Identifier,ManifestEntry> map,
Integer manifestReadParallelism) |
static Set<FileEntry.Identifier> |
FileEntry.readDeletedEntries(ManifestFile manifestFile,
List<ManifestFileMeta> manifestFiles,
Integer manifestReadParallelism) |
static Iterable<ManifestEntry> |
FileEntry.readManifestEntries(ManifestFile manifestFile,
List<ManifestFileMeta> manifestFiles,
Integer manifestReadParallelism) |
Modifier and Type | Field and Description |
---|---|
protected ManifestFile |
FileDeletionBase.manifestFile |
Modifier and Type | Method and Description |
---|---|
static List<ManifestFileMeta> |
ManifestFileMerger.merge(List<ManifestFileMeta> input,
ManifestFile manifestFile,
long suggestedMetaSize,
int suggestedMinMetaCount,
long manifestFullCompactionSize,
RowType partitionType,
Integer manifestReadParallelism)
Merge several
ManifestFileMeta s. |
static Optional<List<ManifestFileMeta>> |
ManifestFileMerger.tryFullCompaction(List<ManifestFileMeta> inputs,
List<ManifestFileMeta> newFilesForAbort,
ManifestFile manifestFile,
long suggestedMetaSize,
long sizeTrigger,
RowType partitionType,
Integer manifestReadParallelism) |
Constructor and Description |
---|
ChangelogDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
FileDeletionBase(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
SnapshotDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean produceChangelog,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
TagDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.