Function datafusion::logical_expr::create_udwf
source · pub fn create_udwf(
name: &str,
input_type: DataType,
return_type: Arc<DataType>,
volatility: Volatility,
partition_evaluator_factory: Arc<dyn Fn() -> Result<Box<dyn PartitionEvaluator>, DataFusionError> + Send + Sync>,
) -> WindowUDF
Expand description
Creates a new UDWF with a specific signature, state type and return type.
The signature and state type must match the PartitionEvaluator
’s implementation`.