bulk-cdk-toolkit-load-iceberg-parquet/io.airbyte.cdk.load.toolkits.iceberg.parquet.io/PartitionedDeltaWriter

PartitionedDeltaWriter

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

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

Constructors

constructor(table: Table, spec: PartitionSpec, format: FileFormat, appenderFactory: FileAppenderFactory<Record>, outputFileFactory: OutputFileFactory, io: FileIO, targetFileSize: Long, schema: Schema, identifierFieldIds: Set<Int>)

Functions

abort

open override fun abort()

open override fun close()

complete

open override fun complete(): WriteResult

dataFiles

open fun dataFiles(): Array<DataFile>

route

open override fun route(row: Record): BaseDeltaTaskWriter.RowDataDeltaWriter

wrapper

open fun wrapper(): InternalRecordWrapper

write

open override fun write(row: Record)