PartitionedDeltaWriter

class PartitionedDeltaWriter(table: Table, spec: PartitionSpec, format: FileFormat, writerFactory: GenericFileWriterFactory, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema, identifierFieldIds: Set<Int>) : BaseDeltaTaskWriter(source)

BaseDeltaTaskWriter implementation that handles delta (insert, update, delete) writes to a partitioned Iceberg org.apache.iceberg.Table.

Constructors

Link copied to clipboard
constructor(table: Table, spec: PartitionSpec, format: FileFormat, writerFactory: GenericFileWriterFactory, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema, identifierFieldIds: Set<Int>)

Functions

Link copied to clipboard
open fun abort()
Link copied to clipboard
open override 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 override fun route(row: Record): BaseDeltaTaskWriter.RowDataDeltaWriter
Link copied to clipboard
open fun wrapper(): InternalRecordWrapper?
Link copied to clipboard
open fun write(row: Record?)