Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.compact | |
org.apache.paimon.mergetree.compact |
Modifier and Type | Method and Description |
---|---|
protected CompactResult |
BucketedAppendCompactManager.FullCompactTask.doCompact() |
protected CompactResult |
BucketedAppendCompactManager.AutoCompactTask.doCompact() |
Modifier and Type | Method and Description |
---|---|
Optional<CompactResult> |
BucketedAppendCompactManager.getCompactionResult(boolean blocking)
Finish current task, and update result files to
BucketedAppendCompactManager.toCompact . |
Modifier and Type | Field and Description |
---|---|
protected Future<CompactResult> |
CompactFutureManager.taskFuture |
Modifier and Type | Method and Description |
---|---|
CompactResult |
CompactTask.call() |
protected abstract CompactResult |
CompactTask.doCompact()
Perform compaction.
|
protected CompactResult |
CompactFutureManager.obtainCompactResult() |
Modifier and Type | Method and Description |
---|---|
Optional<CompactResult> |
NoopCompactManager.getCompactionResult(boolean blocking) |
Optional<CompactResult> |
CompactManager.getCompactionResult(boolean blocking)
Get compaction result.
|
protected Optional<CompactResult> |
CompactFutureManager.innerGetCompactionResult(boolean blocking) |
Modifier and Type | Method and Description |
---|---|
void |
CompactResult.merge(CompactResult that) |
Modifier and Type | Method and Description |
---|---|
protected CompactResult |
MergeTreeCompactTask.doCompact() |
CompactResult |
CompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections)
Rewrite sections to new level.
|
CompactResult |
ChangelogMergeTreeRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
MergeTreeCompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected CompactResult |
MergeTreeCompactRewriter.rewriteCompaction(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
CompactRewriter.upgrade(int outputLevel,
DataFileMeta file)
Upgrade file to new level, usually file data is not rewritten, only the metadata is updated.
|
CompactResult |
ChangelogMergeTreeRewriter.upgrade(int outputLevel,
DataFileMeta file) |
CompactResult |
AbstractCompactRewriter.upgrade(int outputLevel,
DataFileMeta file) |
Modifier and Type | Method and Description |
---|---|
Optional<CompactResult> |
MergeTreeCompactManager.getCompactionResult(boolean blocking)
Finish current task, and update result files to
Levels . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.