| Package | Description |
|---|---|
| org.apache.paimon | |
| org.apache.paimon.flink.lookup | |
| org.apache.paimon.operation | |
| org.apache.paimon.table.source | |
| org.apache.paimon.table.source.splitread |
| Modifier and Type | Method and Description |
|---|---|
MergeFileSplitRead |
KeyValueFileStore.newRead() |
| Constructor and Description |
|---|
IncrementalCompactDiffSplitRead(MergeFileSplitRead mergeRead) |
LookupCompactDiffRead(MergeFileSplitRead mergeRead,
TableSchema schema) |
| Modifier and Type | Method and Description |
|---|---|
MergeFileSplitRead |
MergeFileSplitRead.forceKeepDelete() |
MergeFileSplitRead |
MergeFileSplitRead.withFilter(Predicate predicate) |
MergeFileSplitRead |
MergeFileSplitRead.withIOManager(IOManager ioManager) |
MergeFileSplitRead |
MergeFileSplitRead.withReadKeyType(RowType readKeyType) |
MergeFileSplitRead |
MergeFileSplitRead.withReadType(RowType readType) |
| Constructor and Description |
|---|
KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier,
java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier,
TableSchema schema) |
| Constructor and Description |
|---|
IncrementalDiffSplitRead(MergeFileSplitRead mergeRead) |
| Constructor and Description |
|---|
IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier,
java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner) |
IncrementalDiffReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier,
java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner) |
MergeFileSplitReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier,
java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.