mz_storage::sink::iceberg

Function row_to_recordbatch

Source 
fn row_to_recordbatch(
    row: DiffPair<Row>,
    schema: SchemaRef,
    schema_with_op: SchemaRef,
) -> Result<RecordBatch>
Expand description

Convert a Materialize DiffPair into an Arrow RecordBatch with an __op column. The __op column indicates whether each row is an insert (1) or delete (-1), which the DeltaWriter uses to generate the appropriate Iceberg data/delete files.