Skip to content

Commit

Permalink
migrate window functions rank, dense_rank, and percent_rank to udwf
Browse files Browse the repository at this point in the history
  • Loading branch information
Michael-J-Ward committed Oct 28, 2024
1 parent 2ede85d commit 0096c6c
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/functions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -793,7 +793,7 @@ pub fn rank(
partition_by: Option<Vec<PyExpr>>,
order_by: Option<Vec<PySortExpr>>,
) -> PyResult<PyExpr> {
let window_fn = window_function::rank();
let window_fn = datafusion::functions_window::expr_fn::rank();

add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
}
Expand All @@ -804,7 +804,7 @@ pub fn dense_rank(
partition_by: Option<Vec<PyExpr>>,
order_by: Option<Vec<PySortExpr>>,
) -> PyResult<PyExpr> {
let window_fn = window_function::dense_rank();
let window_fn = datafusion::functions_window::expr_fn::dense_rank();

add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
}
Expand All @@ -815,7 +815,7 @@ pub fn percent_rank(
partition_by: Option<Vec<PyExpr>>,
order_by: Option<Vec<PySortExpr>>,
) -> PyResult<PyExpr> {
let window_fn = window_function::percent_rank();
let window_fn = datafusion::functions_window::expr_fn::percent_rank();

add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
}
Expand Down

0 comments on commit 0096c6c

Please sign in to comment.