datafusion_expr::expr_fn

Function create_udaf

Source
pub fn create_udaf(
    name: &str,
    input_type: Vec<DataType>,
    return_type: Arc<DataType>,
    volatility: Volatility,
    accumulator: AccumulatorFactoryFunction,
    state_type: Arc<Vec<DataType>>,
) -> AggregateUDF
Expand description

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