Function assert_expected_schema

datafusion/expr/src/logical_plan/invariants.rs:114–124

Returns an error if the plan does not have the expected schema. Ignores metadata and nullability.

(schema: &DFSchemaRef, plan: &LogicalPlan)

/// Returns an error if the plan does not have the expected schema.
/// Ignores metadata and nullability.
pub fn assert_expected_schema(schema: &DFSchemaRef, plan: &LogicalPlan) -> Result<()> {
    let compatible = plan.schema().logically_equivalent_names_and_types(schema);

    assert_or_internal_err!(
        compatible,
        "Failed due to a difference in schemas: original schema: {:?}, new schema: {:?}",
        schema,
        plan.schema()
    );
    Ok(())
}

/// Asserts that the subqueries are structured properly with valid node placement.
///