Skip to content

Commit 8313cc9

Browse files
committed
fix: added match arms
1 parent 3ea2c24 commit 8313cc9

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

src/daft-local-execution/src/sinks/window_partition_and_order_by.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,10 @@ impl BlockingSink for WindowPartitionAndOrderBySink {
209209
*offset,
210210
default.clone().map(BoundExpr::new_unchecked),
211211
),
212+
WindowExpr::FirstValue(_, _)
213+
| WindowExpr::LastValue(_, _) => {
214+
unreachable!("first_value/last_value require a frame and cannot appear in a partition+order_by-only window")
215+
}
212216
}
213217
})
214218
.collect::<DaftResult<_>>()?;

0 commit comments

Comments
 (0)