Skip to content

Commit 6fca28b

Browse files
committed
remove row_number() function
row_number was converted to a UDF in datafusion v42 apache/datafusion#12030 This specific functionality needs to be added back in.
1 parent 9cea1fb commit 6fca28b

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

src/functions.rs

-11
Original file line numberDiff line numberDiff line change
@@ -755,16 +755,6 @@ pub fn lag(
755755
add_builder_fns_to_window(window_fn, partition_by, order_by)
756756
}
757757

758-
#[pyfunction]
759-
pub fn row_number(
760-
partition_by: Option<Vec<PyExpr>>,
761-
order_by: Option<Vec<PyExpr>>,
762-
) -> PyResult<PyExpr> {
763-
let window_fn = window_function::row_number();
764-
765-
add_builder_fns_to_window(window_fn, partition_by, order_by)
766-
}
767-
768758
#[pyfunction]
769759
pub fn rank(partition_by: Option<Vec<PyExpr>>, order_by: Option<Vec<PyExpr>>) -> PyResult<PyExpr> {
770760
let window_fn = window_function::rank();
@@ -1002,7 +992,6 @@ pub(crate) fn init_module(m: &Bound<'_, PyModule>) -> PyResult<()> {
1002992
// Window Functions
1003993
m.add_wrapped(wrap_pyfunction!(lead))?;
1004994
m.add_wrapped(wrap_pyfunction!(lag))?;
1005-
m.add_wrapped(wrap_pyfunction!(row_number))?;
1006995
m.add_wrapped(wrap_pyfunction!(rank))?;
1007996
m.add_wrapped(wrap_pyfunction!(dense_rank))?;
1008997
m.add_wrapped(wrap_pyfunction!(percent_rank))?;

0 commit comments

Comments
 (0)