public class KeyValueFileWriterFactory extends Object
FileWriter
s for writing KeyValue
files.Modifier and Type | Class and Description |
---|---|
static class |
KeyValueFileWriterFactory.Builder
Builder of
KeyValueFileWriterFactory . |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileWriterFactory.Builder |
builder(long schemaId,
org.apache.flink.table.types.logical.RowType keyType,
org.apache.flink.table.types.logical.RowType valueType,
FileFormat fileFormat,
FileStorePathFactory pathFactory,
long suggestedFileSize) |
RollingFileWriter<KeyValue,DataFileMeta> |
createRollingChangelogFileWriter(int level) |
RollingFileWriter<KeyValue,DataFileMeta> |
createRollingMergeTreeFileWriter(int level) |
void |
deleteFile(String filename) |
org.apache.flink.table.types.logical.RowType |
keyType() |
DataFilePathFactory |
pathFactory() |
org.apache.flink.table.types.logical.RowType |
valueType() |
public org.apache.flink.table.types.logical.RowType keyType()
public org.apache.flink.table.types.logical.RowType valueType()
@VisibleForTesting public DataFilePathFactory pathFactory()
public RollingFileWriter<KeyValue,DataFileMeta> createRollingMergeTreeFileWriter(int level)
public RollingFileWriter<KeyValue,DataFileMeta> createRollingChangelogFileWriter(int level)
public void deleteFile(String filename)
public static KeyValueFileWriterFactory.Builder builder(long schemaId, org.apache.flink.table.types.logical.RowType keyType, org.apache.flink.table.types.logical.RowType valueType, FileFormat fileFormat, FileStorePathFactory pathFactory, long suggestedFileSize)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.