Package | Description |
---|---|
org.apache.flink.table.store.file.mergetree | |
org.apache.flink.table.store.file.mergetree.compact |
Modifier and Type | Method and Description |
---|---|
static SortedRun |
SortedRun.empty() |
static SortedRun |
SortedRun.fromSingle(DataFileMeta file) |
static SortedRun |
SortedRun.fromSorted(List<DataFileMeta> sortedFiles) |
static SortedRun |
SortedRun.fromUnsorted(List<DataFileMeta> unsortedFiles,
Comparator<org.apache.flink.table.data.RowData> keyComparator) |
SortedRun |
LevelSortedRun.run() |
SortedRun |
Levels.runOfLevel(int level) |
Modifier and Type | Method and Description |
---|---|
static RecordReader<KeyValue> |
MergeTreeReaders.readerForRun(SortedRun run,
KeyValueFileReaderFactory readerFactory) |
Modifier and Type | Method and Description |
---|---|
static RecordReader<KeyValue> |
MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections,
boolean dropDelete,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunction<KeyValue> mergeFunction) |
static RecordReader<KeyValue> |
MergeTreeReaders.readerForSection(List<SortedRun> section,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunctionWrapper<KeyValue> mergeFunctionWrapper) |
Constructor and Description |
---|
LevelSortedRun(int level,
SortedRun run) |
Modifier and Type | Method and Description |
---|---|
List<List<SortedRun>> |
IntervalPartition.partition()
Returns a two-dimensional list of
SortedRun s. |
Modifier and Type | Method and Description |
---|---|
protected static List<DataFileMeta> |
AbstractCompactRewriter.extractFilesFromSections(List<List<SortedRun>> sections) |
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) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.