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 | Field and Description |
---|---|
protected MergeFunctionFactory<KeyValue> |
MergeTreeCompactRewriter.mfFactory |
Modifier and Type | Method and Description |
---|---|
static MergeFunctionFactory<KeyValue> |
DeduplicateMergeFunction.factory() |
static MergeFunctionFactory<KeyValue> |
ValueCountMergeFunction.factory() |
static MergeFunctionFactory<KeyValue> |
PartialUpdateMergeFunction.factory(boolean ignoreDelete,
List<org.apache.flink.table.types.logical.LogicalType> tableTypes) |
Constructor and Description |
---|
FullChangelogMergeTreeCompactRewriter(int maxLevel,
KeyValueFileReaderFactory readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory) |
MergeTreeCompactRewriter(KeyValueFileReaderFactory readerFactory,
KeyValueFileWriterFactory writerFactory,
Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunctionFactory<KeyValue> mfFactory) |
Modifier and Type | Method and Description |
---|---|
static MergeFunctionFactory<KeyValue> |
AggregateMergeFunction.factory(org.apache.flink.configuration.Configuration conf,
List<String> tableNames,
List<org.apache.flink.table.types.logical.LogicalType> tableTypes,
List<String> primaryKeys) |
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) |
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) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.