public class ManifestFileMerger extends Object
Constructor and Description |
---|
ManifestFileMerger() |
Modifier and Type | Method and Description |
---|---|
static List<ManifestFileMeta> |
merge(List<ManifestFileMeta> input,
ManifestFile manifestFile,
long suggestedMetaSize,
int suggestedMinMetaCount,
long manifestFullCompactionSize,
RowType partitionType,
Integer manifestReadParallelism)
Merge several
ManifestFileMeta s. |
static Optional<List<ManifestFileMeta>> |
tryFullCompaction(List<ManifestFileMeta> inputs,
List<ManifestFileMeta> newFilesForAbort,
ManifestFile manifestFile,
long suggestedMetaSize,
long sizeTrigger,
RowType partitionType,
Integer manifestReadParallelism) |
public static List<ManifestFileMeta> merge(List<ManifestFileMeta> input, ManifestFile manifestFile, long suggestedMetaSize, int suggestedMinMetaCount, long manifestFullCompactionSize, RowType partitionType, @Nullable Integer manifestReadParallelism)
ManifestFileMeta
s. ManifestEntry
s representing first adding and
then deleting the same data file will cancel each other.
NOTE: This method is atomic.
public static Optional<List<ManifestFileMeta>> tryFullCompaction(List<ManifestFileMeta> inputs, List<ManifestFileMeta> newFilesForAbort, ManifestFile manifestFile, long suggestedMetaSize, long sizeTrigger, RowType partitionType, @Nullable Integer manifestReadParallelism) throws Exception
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.