Skip to content

Commit cb1e3f0

Browse files
authored
Fix compilation, change row_number() expr_fn to 0 args (#12043)
1 parent e84f343 commit cb1e3f0

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

datafusion/core/src/dataframe/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1710,13 +1710,13 @@ mod tests {
17101710
use datafusion_common::{Constraint, Constraints, ScalarValue};
17111711
use datafusion_common_runtime::SpawnedTask;
17121712
use datafusion_expr::expr::WindowFunction;
1713-
use datafusion_expr::window_function::row_number;
17141713
use datafusion_expr::{
17151714
cast, create_udf, expr, lit, BuiltInWindowFunction, ExprFunctionExt,
17161715
ScalarFunctionImplementation, Volatility, WindowFrame, WindowFrameBound,
17171716
WindowFrameUnits, WindowFunctionDefinition,
17181717
};
17191718
use datafusion_functions_aggregate::expr_fn::{array_agg, count_distinct};
1719+
use datafusion_functions_window::expr_fn::row_number;
17201720
use datafusion_physical_expr::expressions::Column;
17211721
use datafusion_physical_plan::{get_plan_string, ExecutionPlanProperties};
17221722
use sqlparser::ast::NullTreatment;

datafusion/functions-window/src/row_number.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,8 @@ use datafusion_expr::{Expr, PartitionEvaluator, Signature, Volatility, WindowUDF
3131

3232
/// Create a [`WindowFunction`](Expr::WindowFunction) expression for
3333
/// `row_number` user-defined window function.
34-
pub fn row_number(args: Vec<Expr>) -> Expr {
35-
Expr::WindowFunction(WindowFunction::new(row_number_udwf(), args))
34+
pub fn row_number() -> Expr {
35+
Expr::WindowFunction(WindowFunction::new(row_number_udwf(), vec![]))
3636
}
3737

3838
/// Singleton instance of `row_number`, ensures the UDWF is only created once.

datafusion/proto/tests/cases/roundtrip_logical_plan.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -904,7 +904,7 @@ async fn roundtrip_expr_api() -> Result<()> {
904904
vec![lit(1), lit(2), lit(3)],
905905
vec![lit(10), lit(20), lit(30)],
906906
),
907-
row_number(vec![col("a")]),
907+
row_number(),
908908
];
909909

910910
// ensure expressions created with the expr api can be round tripped

0 commit comments

Comments
 (0)