We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2f6e27e commit 38c7705Copy full SHA for 38c7705
native/core/src/execution/planner.rs
@@ -2186,13 +2186,15 @@ impl PhysicalPlanner {
2186
};
2187
2188
let window_frame = WindowFrame::new_bounds(units, lower_bound, upper_bound);
2189
+ let lex_orderings = LexOrdering::new(sort_exprs.to_vec());
2190
+ let sort_phy_exprs = lex_orderings.as_deref().unwrap_or(&[]);
2191
2192
datafusion::physical_plan::windows::create_window_expr(
2193
&window_func,
2194
window_func_name,
2195
&window_args,
2196
partition_by,
- &LexOrdering::new(sort_exprs.to_vec()).unwrap(),
2197
+ sort_phy_exprs,
2198
window_frame.into(),
2199
input_schema.as_ref(),
2200
false, // TODO: Ignore nulls
0 commit comments