Package | Description |
---|---|
org.apache.paimon.mergetree | |
org.apache.paimon.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<InternalRow> keyComparator) |
SortedRun |
LevelSortedRun.run() |
SortedRun |
Levels.runOfLevel(int level) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
LookupUtils.lookup(Comparator<InternalRow> keyComparator,
InternalRow target,
SortedRun level,
BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
LookupUtils.lookup(Levels levels,
InternalRow key,
int startLevel,
BiFunctionWithIOE<InternalRow,SortedRun,T> lookup,
BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup) |
static <T> RecordReader<T> |
MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections,
FileReaderFactory<KeyValue> readerFactory,
Comparator<InternalRow> userKeyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper,
MergeSorter mergeSorter) |
static <T> RecordReader<T> |
MergeTreeReaders.readerForSection(List<SortedRun> section,
FileReaderFactory<KeyValue> readerFactory,
Comparator<InternalRow> userKeyComparator,
FieldsComparator userDefinedSeqComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper,
MergeSorter mergeSorter) |
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) |
protected <T> RecordReader<T> |
MergeTreeCompactRewriter.readerForMergeTree(List<List<SortedRun>> sections,
MergeFunctionWrapper<T> mergeFunctionWrapper) |
CompactResult |
MergeTreeCompactRewriter.rewrite(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
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) |
protected boolean |
LookupMergeTreeCompactRewriter.rewriteChangelog(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected boolean |
FullChangelogMergeTreeCompactRewriter.rewriteChangelog(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected abstract boolean |
ChangelogMergeTreeRewriter.rewriteChangelog(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected CompactResult |
MergeTreeCompactRewriter.rewriteCompaction(int outputLevel,
boolean dropDelete,
List<List<SortedRun>> sections) |
protected boolean |
ChangelogMergeTreeRewriter.rewriteLookupChangelog(int outputLevel,
List<List<SortedRun>> sections) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.