Skip to content

Commit ceb0348

Browse files
committed
find_df_window_func was removed upstream
1 parent 96a647e commit ceb0348

File tree

1 file changed

+1
-10
lines changed

1 file changed

+1
-10
lines changed

src/functions.rs

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -36,10 +36,7 @@ use datafusion::functions_aggregate;
3636
use datafusion::functions_window;
3737
use datafusion::logical_expr::expr::Alias;
3838
use datafusion::logical_expr::sqlparser::ast::NullTreatment as DFNullTreatment;
39-
use datafusion::logical_expr::{
40-
expr::{find_df_window_func, WindowFunction},
41-
lit, Expr, WindowFunctionDefinition,
42-
};
39+
use datafusion::logical_expr::{expr::WindowFunction, lit, Expr, WindowFunctionDefinition};
4340

4441
fn add_builder_fns_to_aggregate(
4542
agg_fn: Expr,
@@ -232,12 +229,6 @@ fn when(when: PyExpr, then: PyExpr) -> PyResult<PyCaseBuilder> {
232229
///
233230
/// NOTE: we search the built-ins first because the `UDAF` versions currently do not have the same behavior.
234231
fn find_window_fn(name: &str, ctx: Option<PySessionContext>) -> PyResult<WindowFunctionDefinition> {
235-
// search built in window functions (soon to be deprecated)
236-
let df_window_func = find_df_window_func(name);
237-
if let Some(df_window_func) = df_window_func {
238-
return Ok(df_window_func);
239-
}
240-
241232
if let Some(ctx) = ctx {
242233
// search UDAFs
243234
let udaf = ctx

0 commit comments

Comments
 (0)