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.