Skip to content

Commit 6aec3f3

Browse files
committed
Use debug_assert
1 parent f5d62bc commit 6aec3f3

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

datafusion/functions-aggregate/src/first_last.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -397,7 +397,7 @@ where
397397
return Ok(true);
398398
}
399399

400-
assert!(new_ordering_values.len() == self.ordering_req.len());
400+
debug_assert!(new_ordering_values.len() == self.ordering_req.len());
401401
let current_ordering = &self.orderings[group_idx];
402402
compare_rows(current_ordering, new_ordering_values, &self.sort_options).map(|x| {
403403
if self.pick_first_in_group {
@@ -478,7 +478,7 @@ where
478478

479479
self.null_builder.set_bit(group_idx, !is_null);
480480

481-
assert!(orderings.len() == self.ordering_req.len());
481+
debug_assert!(orderings.len() == self.ordering_req.len());
482482
let old_size = ScalarValue::size_of_vec(&self.orderings[group_idx]);
483483
self.orderings[group_idx].clear();
484484
self.orderings[group_idx].extend_from_slice(orderings);
@@ -660,7 +660,7 @@ where
660660
ordering_cols.push(Vec::with_capacity(self.orderings.len()));
661661
}
662662
for row in orderings.into_iter() {
663-
assert_eq!(row.len(), self.ordering_req.len());
663+
debug_assert!(row.len() == self.ordering_req.len());
664664
for (col_idx, ordering) in row.into_iter().enumerate() {
665665
ordering_cols[col_idx].push(ordering);
666666
}

0 commit comments

Comments
 (0)