Function deltalake::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> + Sync + Send>
) -> 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`.