Skip to content

Commit cd0f759

Browse files
committed
Fix clippy lints
1 parent 290b24f commit cd0f759

File tree

1 file changed

+6
-8
lines changed

1 file changed

+6
-8
lines changed

parquet/src/arrow/record_reader.rs

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -383,14 +383,12 @@ impl<T: DataType> RecordReader<T> {
383383
let mut end_of_last_record = self.num_values;
384384

385385
for current in self.num_values..self.values_written {
386-
if buf[current] == 0 {
387-
if current != end_of_last_record {
388-
records_read += 1;
389-
end_of_last_record = current;
390-
391-
if records_read == records_to_read {
392-
break;
393-
}
386+
if buf[current] == 0 && current != end_of_last_record {
387+
records_read += 1;
388+
end_of_last_record = current;
389+
390+
if records_read == records_to_read {
391+
break;
394392
}
395393
}
396394
}

0 commit comments

Comments
 (0)