toRecord
fun toRecord(record: EnrichedDestinationRecordAirbyteValue, stream: DestinationStream, tableSchema: Schema): Record
Converts an Airbyte EnrichedDestinationRecordAirbyteValue into an Iceberg Record. The converted record will be wrapped to include Operation information, which is used by the writer to determine how to write the data to the underlying Iceberg files.
Return
An Iceberg Record representation of the EnrichedDestinationRecordAirbyteValue.
Parameters
record
The Airbyte EnrichedDestinationRecordAirbyteValue record to be converted for writing by Iceberg.
stream
The Airbyte DestinationStream that contains information about the stream.
tableSchema
The Iceberg Table.