Function deltalake::datafusion::logical_expr::expr_fn::create_udaf

pub fn create_udaf(
    name: &str,
    input_type: Vec<DataType>,
    return_type: Arc<DataType>,
    volatility: Volatility,
    accumulator: Arc<dyn Fn(&DataType) -> Result<Box<dyn Accumulator>, DataFusionError> + Sync + Send>,
    state_type: Arc<Vec<DataType>>
) -> AggregateUDF

Creates a new UDAF with a specific signature, state type and return type. The signature and state type must match the Accumulator's implementation.