Skip to main content

validate_decoded_payload_expr

Function validate_decoded_payload_expr 

Source
fn validate_decoded_payload_expr(
    expr: &Arc<dyn PhysicalExpr>,
    input_schema: &Schema,
) -> Result<()>
Expand description

Validates decoded dynamic filter physical expressions against the receiver-side schema.

Rejects out-of-bounds column indexes and, as a defensive check, rejects columns whose name disagrees with the corresponding schema field. DataFusion physical Column is index-authoritative, so a name mismatch usually indicates a coordinator/receiver schema inconsistency that should be surfaced loudly.