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