pub fn create_udaf(
    name: &str,
    input_type: DataType,
    return_type: Arc<DataType>,
    volatility: Volatility,
    accumulator: Arc<dyn Fn(&DataType) -> Result<Box<dyn Accumulator, Global>, DataFusionError> + Send + Sync>,
    state_type: Arc<Vec<DataType, Global>>
) -> 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.