Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.io | |
org.apache.paimon.operation | |
org.apache.paimon.table |
Constructor and Description |
---|
KeyValueFileStore(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
boolean crossPartitionUpdate,
CoreOptions options,
RowType partitionType,
RowType bucketKeyType,
RowType keyType,
RowType valueType,
KeyValueFieldsExtractor keyValueFieldsExtractor,
MergeFunctionFactory<KeyValue> mfFactory,
String tableName,
CatalogEnvironment catalogEnvironment) |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileReaderFactory.Builder |
KeyValueFileReaderFactory.builder(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
RowType keyType,
RowType valueType,
FileFormatDiscover formatDiscover,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor,
CoreOptions options) |
Constructor and Description |
---|
KeyValueFileStoreScan(RowType partitionType,
ScanBucketFilter bucketFilter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
KeyValueFieldsExtractor keyValueFieldsExtractor,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets,
Integer scanManifestParallelism,
boolean deletionVectorsEnabled,
CoreOptions.MergeEngine mergeEngine,
CoreOptions.ChangelogProducer changelogProducer) |
KeyValueFileStoreWrite(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
String commitUser,
RowType partitionType,
RowType keyType,
RowType valueType,
java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier,
java.util.function.Supplier<FieldsComparator> udsComparatorSupplier,
java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier,
MergeFunctionFactory<KeyValue> mfFactory,
FileStorePathFactory pathFactory,
Map<String,FileStorePathFactory> format2PathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
IndexMaintainer.Factory<KeyValue> indexFactory,
DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory,
CoreOptions options,
KeyValueFieldsExtractor extractor,
String tableName) |
Modifier and Type | Class and Description |
---|---|
static class |
PrimaryKeyTableUtils.PrimaryKeyFieldsExtractor
Primary key fields extractor.
|
Modifier and Type | Method and Description |
---|---|
static MergeFunctionFactory<KeyValue> |
PrimaryKeyTableUtils.createMergeFunctionFactory(TableSchema tableSchema,
KeyValueFieldsExtractor extractor) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.