Constructor and Description |
---|
KeyValueFileStore(SchemaManager schemaManager,
long schemaId,
CoreOptions options,
org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
KeyValueFieldsExtractor keyValueFieldsExtractor,
MergeFunctionFactory<KeyValue> mfFactory) |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileReaderFactory.Builder |
KeyValueFileReaderFactory.builder(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
Constructor and Description |
---|
KeyValueFileStoreRead(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor) |
KeyValueFileStoreScan(org.apache.flink.table.types.logical.RowType partitionType,
org.apache.flink.table.types.logical.RowType bucketKeyType,
org.apache.flink.table.types.logical.RowType keyType,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
long schemaId,
KeyValueFieldsExtractor keyValueFieldsExtractor,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
int numOfBuckets,
boolean checkNumOfBuckets) |
KeyValueFileStoreWrite(SchemaManager schemaManager,
long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
java.util.function.Supplier<Comparator<org.apache.flink.table.data.RowData>> keyComparatorSupplier,
MergeFunctionFactory<KeyValue> mfFactory,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
KeyValueFieldsExtractor extractor) |
Modifier and Type | Method and Description |
---|---|
static BulkFormatMapping.BulkFormatMappingBuilder |
BulkFormatMapping.newBuilder(FileFormat fileFormat,
KeyValueFieldsExtractor extractor,
int[][] keyProjection,
int[][] valueProjection,
List<Predicate> filters) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.