Skip to content

Commit 627887a

Browse files
committed
Use debug_assert
1 parent 9171bf8 commit 627887a

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

datafusion/functions-aggregate/src/first_last.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,7 @@ impl<S: ValueState> FirstLastGroupsAccumulator<S> {
426426
return Ok(true);
427427
}
428428

429-
assert!(new_ordering_values.len() == self.ordering_req.len());
429+
debug_assert!(new_ordering_values.len() == self.ordering_req.len());
430430
let current_ordering = &self.orderings[group_idx];
431431
compare_rows(current_ordering, new_ordering_values, &self.sort_options).map(|x| {
432432
if self.pick_first_in_group {
@@ -485,7 +485,7 @@ impl<S: ValueState> FirstLastGroupsAccumulator<S> {
485485
self.state.update(group_idx, array, idx)?;
486486
self.is_sets.set_bit(group_idx, true);
487487

488-
assert!(orderings.len() == self.ordering_req.len());
488+
debug_assert!(orderings.len() == self.ordering_req.len());
489489
let old_size = ScalarValue::size_of_vec(&self.orderings[group_idx]);
490490
self.orderings[group_idx].clear();
491491
self.orderings[group_idx].extend_from_slice(orderings);
@@ -650,7 +650,7 @@ impl<S: ValueState + 'static> GroupsAccumulator for FirstLastGroupsAccumulator<S
650650
ordering_cols.push(Vec::with_capacity(self.orderings.len()));
651651
}
652652
for row in orderings.into_iter() {
653-
assert_eq!(row.len(), self.ordering_req.len());
653+
debug_assert!(row.len() == self.ordering_req.len());
654654
for (col_idx, ordering) in row.into_iter().enumerate() {
655655
ordering_cols[col_idx].push(ordering);
656656
}

0 commit comments

Comments
 (0)