| 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 |
|---|---|
RawFileSplitRead |
KeyValueFileStore.newBatchRawFileRead() |
RawFileSplitRead |
AppendOnlyFileStore.newRead() |
| Modifier and Type | Method and Description |
|---|---|
RawFileSplitRead |
RawFileSplitRead.withFilter(Predicate predicate) |
RawFileSplitRead |
RawFileSplitRead.withProjection(int[][] projectedFields) |
| Constructor and Description |
|---|
AppendOnlyFileStoreWrite(FileIO fileIO,
RawFileSplitRead read,
long schemaId,
String commitUser,
RowType rowType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
BucketMode bucketMode,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
| Constructor and Description |
|---|
KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier,
java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier,
TableSchema schema) |
| Constructor and Description |
|---|
RawFileSplitReadProvider(java.util.function.Supplier<RawFileSplitRead> supplier,
java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.