| Package | Description |
|---|---|
| org.apache.paimon | |
| org.apache.paimon.operation | |
| org.apache.paimon.table.source | |
| org.apache.paimon.table.source.splitread |
| Modifier and Type | Method and Description |
|---|---|
MergeFileSplitRead |
KeyValueFileStore.newRead() |
| Modifier and Type | Method and Description |
|---|---|
MergeFileSplitRead |
MergeFileSplitRead.forceKeepDelete() |
MergeFileSplitRead |
MergeFileSplitRead.withFilter(Predicate predicate) |
MergeFileSplitRead |
MergeFileSplitRead.withIOManager(IOManager ioManager) |
MergeFileSplitRead |
MergeFileSplitRead.withKeyProjection(int[][] projectedFields) |
MergeFileSplitRead |
MergeFileSplitRead.withProjection(int[][] projectedFields) |
| 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–2024 The Apache Software Foundation. All rights reserved.