Skip to main content

validate_sink_schema

Function validate_sink_schema 

Source
pub fn validate_sink_schema(
    pipeline: &Schema,
    table: &Schema,
) -> Result<(), ConnectorError>
Expand description

Validates an Arrow pipeline schema against an Iceberg-derived Arrow schema.

ยงErrors

Returns a schema mismatch for missing fields or unsafe type changes.