Function plan_any_op

datafusion/sql/src/expr/mod.rs:1268–1304

Plans a ` ANY( )` expression for non-subquery operands.

(
    left_expr: Expr,
    right_expr: Expr,
    compare_op: &BinaryOperator,
)

/// Plans a `<left> <op> ANY(<right>)` expression for non-subquery operands.
fn plan_any_op(
    left_expr: Expr,
    right_expr: Expr,
    compare_op: &BinaryOperator,
) -> Result<Expr> {
    match compare_op {
        BinaryOperator::Eq => Ok(array_has(right_expr, left_expr)),
        BinaryOperator::NotEq => {
            let min = array_min(right_expr.clone());
            let max = array_max(right_expr.clone());
            // NOT EQ is true when either bound differs from left
            let comparison = min
                .not_eq(left_expr.clone())
                .or(max.clone().not_eq(left_expr));
            any_op_with_null_handling(max, comparison, right_expr)
        }
        BinaryOperator::Gt => {
            let min = array_min(right_expr.clone());
            any_op_with_null_handling(min.clone(), min.lt(left_expr), right_expr)
        }
        BinaryOperator::Lt => {
            let max = array_max(right_expr.clone());
            any_op_with_null_handling(max.clone(), max.gt(left_expr), right_expr)
        }
        BinaryOperator::GtEq => {
            let min = array_min(right_expr.clone());
            any_op_with_null_handling(min.clone(), min.lt_eq(left_expr), right_expr)
        }
        BinaryOperator::LtEq => {
            let max = array_max(right_expr.clone());
            any_op_with_null_handling(max.clone(), max.gt_eq(left_expr), right_expr)
        }
        _ => plan_err!(
            "Unsupported AnyOp: '{compare_op}', only '=', '<>', '>', '<', '>=', '<=' are supported"
        ),
    }
}

/// Plans `needle <compare_op> ALL(haystack)` with proper SQL NULL semantics.
///