Skip to content

Commit 6429c60

Browse files
committed
Merge branch 'xuanwo/asof-float-equality' into xuanwo/asof-logical
2 parents 4eb3c28 + 6b0bd0e commit 6429c60

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

‎datafusion/physical-plan/src/joins/asof_join.rs‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,9 @@ impl ExecutionPlan for AsOfJoinExec {
379379
}
380380

381381
fn maintains_input_order(&self) -> Vec<bool> {
382-
vec![false, false]
382+
// ASOF emits exactly one row for each left row and never reorders the
383+
// left input. The right input is scanned independently.
384+
vec![true, false]
383385
}
384386

385387
fn children(&self) -> Vec<&Arc<dyn ExecutionPlan>> {

0 commit comments

Comments
 (0)