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

RowDataDeltaWriter

open inner class RowDataDeltaWriter : BaseTaskWriter.BaseEqualityDeltaWriter

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

Constructors

Link copied to clipboard
constructor(partition: PartitionKey)

Functions

Link copied to clipboard
open fun close()
Link copied to clipboard
open fun delete(p: T)
Link copied to clipboard
open fun deleteKey(p: T)
Link copied to clipboard
open fun write(p: T)