Method try_new

datafusion/physical-expr/src/expressions/lambda.rs:64–75

Create a new lambda expression with the given parameters and body

(params: Vec<String>, body: Arc<dyn PhysicalExpr>)

impl LambdaExpr {
    /// Create a new lambda expression with the given parameters and body
    pub fn try_new(params: Vec<String>, body: Arc<dyn PhysicalExpr>) -> Result<Self> {
        if !all_unique(&params) {
            return plan_err!(
                "lambda params must be unique, got ({})",
                params.join(", ")
            );
        }

        check_async_udf(&body)?;

        Ok(Self::new(params, body))
    }

    fn new(params: Vec<String>, body: Arc<dyn PhysicalExpr>) -> Self {
        let mut used_column_indices = HashSet::new();