diff --git a/src/functions.rs b/src/functions.rs index 42203d7b4..8f5f3f190 100644 --- a/src/functions.rs +++ b/src/functions.rs @@ -140,7 +140,7 @@ fn window( ctx.and_then(|ctx| { ctx.ctx .udaf(name) - .map(|fun| datafusion_expr::WindowFunction::AggregateUDF(fun)) + .map(datafusion_expr::WindowFunction::AggregateUDF) .ok() }) });