Function register_all

datafusion/functions-nested/src/lib.rs:213–236

Registers all enabled packages with a [`FunctionRegistry`]

(registry: &mut dyn FunctionRegistry)

/// Registers all enabled packages with a [`FunctionRegistry`]
pub fn register_all(registry: &mut dyn FunctionRegistry) -> Result<()> {
    let functions: Vec<Arc<ScalarUDF>> = all_default_nested_functions();
    functions.into_iter().try_for_each(|udf| {
        let existing_udf = registry.register_udf(udf)?;
        if let Some(existing_udf) = existing_udf {
            debug!("Overwrite existing UDF: {}", existing_udf.name());
        }
        Ok(()) as Result<()>
    })?;

    let functions: Vec<Arc<HigherOrderUDF>> = all_default_higher_order_functions();
    functions.into_iter().try_for_each(|function| {
        let existing_function = registry.register_higher_order_function(function)?;
        if let Some(existing_function) = existing_function {
            debug!(
                "Overwrite existing higher-order function: {}",
                existing_function.name()
            );
        }
        Ok(()) as Result<()>
    })?;

    Ok(())
}

#[cfg(test)]
mod tests {