Package | Description |
---|---|
org.apache.flink.table.store.file.append | |
org.apache.flink.table.store.file.compact | |
org.apache.flink.table.store.file.mergetree.compact |
Modifier and Type | Method and Description |
---|---|
protected CompactResult |
AppendOnlyCompactManager.IterativeCompactTask.doCompact(List<DataFileMeta> inputs) |
protected CompactResult |
AppendOnlyCompactManager.AutoCompactTask.doCompact(List<DataFileMeta> inputs) |
Modifier and Type | Method and Description |
---|---|
Optional<CompactResult> |
AppendOnlyCompactManager.getCompactionResult(boolean blocking)
Finish current task, and update result files to
AppendOnlyCompactManager.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(List<DataFileMeta> inputs)
Perform compaction.
|
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(List<DataFileMeta> inputs) |
CompactResult |
MergeTreeCompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
FullChangelogMergeTreeCompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
CompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected CompactResult |
MergeTreeCompactRewriter.rewriteCompaction(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
CompactResult |
AbstractCompactRewriter.upgrade(int outputLevel,
DataFileMeta file) |
CompactResult |
FullChangelogMergeTreeCompactRewriter.upgrade(int outputLevel,
DataFileMeta file) |
CompactResult |
CompactRewriter.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 © 2019–2023 The Apache Software Foundation. All rights reserved.