org.apache.paimon.io

Class RowDataRollingFileWriter

java.lang.Object

org.apache.paimon.io.RollingFileWriter<InternalRow,DataFileMeta>

org.apache.paimon.io.RowDataRollingFileWriter

All Implemented Interfaces:

Closeable, AutoCloseable, FileWriter<InternalRow,List<DataFileMeta>>

public class RowDataRollingFileWriter
extends RollingFileWriter<InternalRow,DataFileMeta>

RollingFileWriter for data files containing InternalRow.

Constructor Summary

Constructors

Constructor and Description
RowDataRollingFileWriter(FileIO fileIO, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, DataFilePathFactory pathFactory, LongCounter seqNumCounter, String fileCompression, SimpleColStatsCollector.Factory[] statsCollectors, FileIndexOptions fileIndexOptions, FileSource fileSource, boolean asyncFileWrite)

Method Summary

Methods inherited from class org.apache.paimon.io.RollingFileWriter

abort, close, recordCount, result, targetFileSize, write, writeBundle

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.io.FileWriter

write, write, write

Constructor Detail

RowDataRollingFileWriter

public RowDataRollingFileWriter(FileIO fileIO,
                                long schemaId,
                                FileFormat fileFormat,
                                long targetFileSize,
                                RowType writeSchema,
                                DataFilePathFactory pathFactory,
                                LongCounter seqNumCounter,
                                String fileCompression,
                                SimpleColStatsCollector.Factory[] statsCollectors,
                                FileIndexOptions fileIndexOptions,
                                FileSource fileSource,
                                boolean asyncFileWrite)