Package | Description |
---|---|
org.apache.flink.table.store.file.mergetree.compact |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCompactRewriter
Common implementation of
CompactRewriter . |
class |
FullChangelogMergeTreeCompactRewriter
A
MergeTreeCompactRewriter which produces changelog files for each full compaction. |
class |
MergeTreeCompactRewriter
Default
CompactRewriter for merge trees. |
Constructor and Description |
---|
MergeTreeCompactManager(ExecutorService executor,
Levels levels,
CompactStrategy strategy,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
long minFileSize,
int numSortedRunStopTrigger,
CompactRewriter rewriter) |
MergeTreeCompactTask(Comparator<org.apache.flink.table.data.RowData> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.