Skip to content

Commit 0096c6c

Browse files
migrate window functions rank, dense_rank, and percent_rank to udwf
Ref: apache/datafusion#12648
1 parent 2ede85d commit 0096c6c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/functions.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -793,7 +793,7 @@ pub fn rank(
793793
partition_by: Option<Vec<PyExpr>>,
794794
order_by: Option<Vec<PySortExpr>>,
795795
) -> PyResult<PyExpr> {
796-
let window_fn = window_function::rank();
796+
let window_fn = datafusion::functions_window::expr_fn::rank();
797797

798798
add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
799799
}
@@ -804,7 +804,7 @@ pub fn dense_rank(
804804
partition_by: Option<Vec<PyExpr>>,
805805
order_by: Option<Vec<PySortExpr>>,
806806
) -> PyResult<PyExpr> {
807-
let window_fn = window_function::dense_rank();
807+
let window_fn = datafusion::functions_window::expr_fn::dense_rank();
808808

809809
add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
810810
}
@@ -815,7 +815,7 @@ pub fn percent_rank(
815815
partition_by: Option<Vec<PyExpr>>,
816816
order_by: Option<Vec<PySortExpr>>,
817817
) -> PyResult<PyExpr> {
818-
let window_fn = window_function::percent_rank();
818+
let window_fn = datafusion::functions_window::expr_fn::percent_rank();
819819

820820
add_builder_fns_to_window(window_fn, partition_by, None, order_by, None)
821821
}

0 commit comments

Comments
 (0)