org.apache.paimon.io

Class KeyValueFileWriterFactory

java.lang.Object

org.apache.paimon.io.KeyValueFileWriterFactory

public class KeyValueFileWriterFactory
extends Object

A factory to create FileWriters for writing KeyValue files.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KeyValueFileWriterFactory.Builder Builder of KeyValueFileWriterFactory.

Method Summary

Modifier and Type	Method and Description
static KeyValueFileWriterFactory.Builder	builder(FileIO fileIO, long schemaId, RowType keyType, RowType valueType, FileFormat fileFormat, Map<String,FileStorePathFactory> format2PathFactory, long suggestedFileSize)
void	copyFile(DataFileMeta sourceFile, DataFileMeta targetFile)
RollingFileWriter<KeyValue,DataFileMeta>	createRollingChangelogFileWriter(int level)
RollingFileWriter<KeyValue,DataFileMeta>	createRollingMergeTreeFileWriter(int level, FileSource fileSource)
void	deleteFile(DataFileMeta file)
FileIO	getFileIO()
RowType	keyType()
String	newChangelogFileName(int level)
DataFilePathFactory	pathFactory(int level)
RowType	valueType()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

keyType

public RowType keyType()

valueType

public RowType valueType()

pathFactory

@VisibleForTesting
public DataFilePathFactory pathFactory(int level)

createRollingMergeTreeFileWriter

public RollingFileWriter<KeyValue,DataFileMeta> createRollingMergeTreeFileWriter(int level,
                                                                                 FileSource fileSource)

createRollingChangelogFileWriter

public RollingFileWriter<KeyValue,DataFileMeta> createRollingChangelogFileWriter(int level)

deleteFile

public void deleteFile(DataFileMeta file)

copyFile

public void copyFile(DataFileMeta sourceFile,
                     DataFileMeta targetFile)
              throws IOException

Throws:

IOException

getFileIO

public FileIO getFileIO()

newChangelogFileName

public String newChangelogFileName(int level)

builder

public static KeyValueFileWriterFactory.Builder builder(FileIO fileIO,
                                                        long schemaId,
                                                        RowType keyType,
                                                        RowType valueType,
                                                        FileFormat fileFormat,
                                                        Map<String,FileStorePathFactory> format2PathFactory,
                                                        long suggestedFileSize)