UnpartitionedAppendWriter

class UnpartitionedAppendWriter(spec: PartitionSpec, format: FileFormat, writerFactory: GenericFileWriterFactory, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long) : UnpartitionedWriter<Record> (source)

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

Constructors

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

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(record: Record?)