public class KeyValueFileStore extends AbstractFileStore<KeyValue>
options, partitionType, schemaId, schemaManager
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 |
---|---|
Comparator<org.apache.flink.table.data.RowData> |
newKeyComparator() |
KeyValueFileStoreRead |
newRead() |
KeyValueFileStoreScan |
newScan() |
KeyValueFileStoreWrite |
newWrite(String commitUser) |
manifestFileFactory, manifestListFactory, newCommit, newExpire, newPartitionExpire, options, partitionType, pathFactory, snapshotManager
public 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)
public KeyValueFileStoreScan newScan()
public KeyValueFileStoreRead newRead()
public KeyValueFileStoreWrite newWrite(String commitUser)
public Comparator<org.apache.flink.table.data.RowData> newKeyComparator()
newKeyComparator
in class AbstractFileStore<KeyValue>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.