org.apache.paimon.io

Class KeyValueDataFileWriterImpl

java.lang.Object

org.apache.paimon.io.SingleFileWriter<T,R>

org.apache.paimon.io.StatsCollectingSingleFileWriter<KeyValue,DataFileMeta>

org.apache.paimon.io.KeyValueDataFileWriter

org.apache.paimon.io.KeyValueDataFileWriterImpl

All Implemented Interfaces:

Closeable, AutoCloseable, FileWriter<KeyValue,DataFileMeta>

public class KeyValueDataFileWriterImpl
extends KeyValueDataFileWriter

Write data files containing KeyValues.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.io.SingleFileWriter

SingleFileWriter.AbortExecutor

Field Summary

Fields inherited from class org.apache.paimon.io.KeyValueDataFileWriter

keyType, valueType

Fields inherited from class org.apache.paimon.io.SingleFileWriter

closed, fileIO, outputBytes, path

Constructor Summary

Constructors

Constructor and Description
KeyValueDataFileWriterImpl(FileIO fileIO, FileWriterContext context, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, long schemaId, int level, CoreOptions options, FileSource fileSource, FileIndexOptions fileIndexOptions, boolean isExternalPath)

Method Summary

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

close, result, write

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

fieldStats, writeBundle

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

abort, abortExecutor, path, reachTargetSize, recordCount, writeImpl

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

KeyValueDataFileWriterImpl

public KeyValueDataFileWriterImpl(FileIO fileIO,
                                  FileWriterContext context,
                                  Path path,
                                  java.util.function.Function<KeyValue,InternalRow> converter,
                                  RowType keyType,
                                  RowType valueType,
                                  long schemaId,
                                  int level,
                                  CoreOptions options,
                                  FileSource fileSource,
                                  FileIndexOptions fileIndexOptions,
                                  boolean isExternalPath)