public class KeyValueFileStoreWrite extends MemoryFileStoreWrite<KeyValue>
AbstractFileStoreWrite.WriterContainer<T>
ioManager, snapshotManager, writers
Constructor and Description |
---|
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 |
---|---|
AbstractFileStoreWrite.WriterContainer<KeyValue> |
createEmptyWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
ExecutorService compactExecutor)
Create an empty
RecordWriter from partition and bucket. |
AbstractFileStoreWrite.WriterContainer<KeyValue> |
createWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
ExecutorService compactExecutor)
Create a
RecordWriter from partition and bucket. |
notifyNewWriter
close, compact, notifyNewFiles, prepareCommit, scanExistingFileMetas, withIOManager, withOverwrite, write
public 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)
public AbstractFileStoreWrite.WriterContainer<KeyValue> createWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, ExecutorService compactExecutor)
AbstractFileStoreWrite
RecordWriter
from partition and bucket.createWriterContainer
in class AbstractFileStoreWrite<KeyValue>
public AbstractFileStoreWrite.WriterContainer<KeyValue> createEmptyWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, ExecutorService compactExecutor)
AbstractFileStoreWrite
RecordWriter
from partition and bucket.createEmptyWriterContainer
in class AbstractFileStoreWrite<KeyValue>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.