Skip to main content

validate_sink_schema

laminar_connectors::lakehouse::iceberg_config

Function validate_sink_schema 

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

Validates that a pipeline’s output schema is compatible with an Iceberg table’s Arrow schema.

Every field in pipeline must exist in table with a matching or safely-widenable type. Extra columns in table are acceptable (Iceberg fills them with nulls).

§Errors

Returns ConnectorError::SchemaMismatch on incompatible fields.