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

IcebergTableWriterFactory

@Singleton

class IcebergTableWriterFactory(icebergUtil: IcebergUtil)

Factory that creates Iceberg BaseTaskWriter instances to support writing records to Iceberg data files.

The factory takes into account whether partitioning is used on the target table and whether primary keys are configured on the destination table's schema.

Constructors

IcebergTableWriterFactory

constructor(icebergUtil: IcebergUtil)

Functions

create

fun create(table: Table, generationId: String, importType: ImportType, schema: Schema): BaseTaskWriter<Record>

Creates a new BaseTaskWriter based on the configuration of the destination target Table.