Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.compact | |
org.apache.paimon.mergetree.compact | |
org.apache.paimon.operation.metrics |
Constructor and Description |
---|
AutoCompactTask(DeletionVectorsMaintainer dvMaintainer,
List<DataFileMeta> toCompact,
BucketedAppendCompactManager.CompactRewriter rewriter,
CompactionMetrics.Reporter metricsReporter) |
BucketedAppendCompactManager(ExecutorService executor,
List<DataFileMeta> restored,
DeletionVectorsMaintainer dvMaintainer,
int minFileNum,
int maxFileNum,
long targetFileSize,
BucketedAppendCompactManager.CompactRewriter rewriter,
CompactionMetrics.Reporter metricsReporter) |
FullCompactTask(DeletionVectorsMaintainer dvMaintainer,
Collection<DataFileMeta> inputs,
long targetFileSize,
BucketedAppendCompactManager.CompactRewriter rewriter,
CompactionMetrics.Reporter metricsReporter) |
Constructor and Description |
---|
CompactTask(CompactionMetrics.Reporter metricsReporter) |
Constructor and Description |
---|
MergeTreeCompactManager(ExecutorService executor,
Levels levels,
CompactStrategy strategy,
Comparator<InternalRow> keyComparator,
long compactionFileSize,
int numSortedRunStopTrigger,
CompactRewriter rewriter,
CompactionMetrics.Reporter metricsReporter,
DeletionVectorsMaintainer dvMaintainer,
boolean lazyGenDeletionFile) |
MergeTreeCompactTask(Comparator<InternalRow> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete,
int maxLevel,
CompactionMetrics.Reporter metricsReporter,
java.util.function.Supplier<CompactDeletionFile> compactDfSupplier) |
Modifier and Type | Method and Description |
---|---|
CompactionMetrics.Reporter |
CompactionMetrics.createReporter(BinaryRow partition,
int bucket) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.