PartitionedAppendWriter

class PartitionedAppendWriter(spec: PartitionSpec, format: FileFormat, writerFactory: GenericFileWriterFactory, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema) : PartitionedWriter<Record> (source)

org.apache.iceberg.io.BaseTaskWriter implementation that handles append-only writes to a partitioned Iceberg org.apache.iceberg.Table.

Constructors

Link copied to clipboard
constructor(spec: PartitionSpec, format: FileFormat, writerFactory: GenericFileWriterFactory, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema)

Functions

Link copied to clipboard
open fun abort()
Link copied to clipboard
open fun close()
Link copied to clipboard
open fun complete(): WriteResult?
Link copied to clipboard
open fun dataFiles(): Array<out DataFile?>?
Link copied to clipboard
open fun write(row: Record?)