Function datafusion::logical_plan::create_udaf
source · [−]pub fn create_udaf(
name: &str,
input_type: DataType,
return_type: Arc<DataType>,
volatility: Volatility,
accumulator: Arc<dyn Fn() + Sync + Send + 'static>,
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
.