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

RowDataDeltaWriter

open inner class RowDataDeltaWriter : BaseTaskWriter.BaseEqualityDeltaWriter(source)

Custom writer implementation that supports inserting and deleting records based on equality.

Constructors

RowDataDeltaWriter

constructor(partition: PartitionKey)

Functions

open fun close()

open fun delete(row: T)

open fun deleteKey(key: T)

open fun write(row: T)