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–2024 The Apache Software Foundation. All rights reserved.