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.
Return
The BaseTaskWriter that writes records to the target Table.
Parameters
table
An Iceberg Table
generationId
ID assigned to the data generation associated with the incoming data.
importType
The ImportType of the sync job.