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(String sourceFileName, String targetFileName, int level)
RollingFileWriter<KeyValue,DataFileMeta>	createRollingChangelogFileWriter(int level)
RollingFileWriter<KeyValue,DataFileMeta>	createRollingMergeTreeFileWriter(int level, FileSource fileSource)
void	deleteFile(String filename, int level)
FileIO	getFileIO()
RowType	keyType()
Path	newChangelogPath(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(String filename,
                       int level)

copyFile

public void copyFile(String sourceFileName,
                     String targetFileName,
                     int level)
              throws IOException

Throws:

IOException

getFileIO

public FileIO getFileIO()

newChangelogPath

public Path newChangelogPath(int level)

builder

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