Skip to content

Commit 2ede85d

Browse files
migrate window functions lead and lag to udwf
Ref: apache/datafusion#12802
1 parent 7eb52c9 commit 2ede85d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/functions.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -757,7 +757,7 @@ pub fn lead(
757757
partition_by: Option<Vec<PyExpr>>,
758758
order_by: Option<Vec<PySortExpr>>,
759759
) -> PyResult<PyExpr> {
760-
let window_fn = window_function::lead(arg.expr, Some(shift_offset), default_value);
760+
let window_fn = datafusion::functions_window::expr_fn::lead(arg.expr, Some(shift_offset), default_value);
761761

762762
add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
763763
}
@@ -771,7 +771,7 @@ pub fn lag(
771771
partition_by: Option<Vec<PyExpr>>,
772772
order_by: Option<Vec<PySortExpr>>,
773773
) -> PyResult<PyExpr> {
774-
let window_fn = window_function::lag(arg.expr, Some(shift_offset), default_value);
774+
let window_fn = datafusion::functions_window::expr_fn::lag(arg.expr, Some(shift_offset), default_value);
775775

776776
add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
777777
}

0 commit comments

Comments
 (0)