diff --git a/crates/polars-io/src/parquet/read/read_impl.rs b/crates/polars-io/src/parquet/read/read_impl.rs index 2eb72b4b943a..e0a096de498e 100644 --- a/crates/polars-io/src/parquet/read/read_impl.rs +++ b/crates/polars-io/src/parquet/read/read_impl.rs @@ -905,8 +905,8 @@ pub fn read_parquet( let mut do_prefilter = false; do_prefilter |= prefilter_env == Ok("1"); // Force enable - do_prefilter |= (num_live_variables * n_row_groups >= POOL.current_num_threads() - && materialized_projection.len() >= num_live_variables); + do_prefilter |= num_live_variables * n_row_groups >= POOL.current_num_threads() + && materialized_projection.len() >= num_live_variables; do_prefilter &= prefilter_env != Ok("0"); // Force disable diff --git a/crates/polars-parquet/src/arrow/read/deserialize/nested_utils.rs b/crates/polars-parquet/src/arrow/read/deserialize/nested_utils.rs index f4a53a123089..78b4a813693d 100644 --- a/crates/polars-parquet/src/arrow/read/deserialize/nested_utils.rs +++ b/crates/polars-parquet/src/arrow/read/deserialize/nested_utils.rs @@ -218,7 +218,7 @@ pub struct BatchedNestedDecoder<'a> { validity: &'a mut MutableBitmap, } -impl<'a> BatchedNestedDecoder<'a> { +impl BatchedNestedDecoder<'_> { fn push_valid(&mut self) -> ParquetResult<()> { self.push_n_valids(1) } diff --git a/crates/polars-parquet/src/arrow/read/deserialize/utils/mod.rs b/crates/polars-parquet/src/arrow/read/deserialize/utils/mod.rs index 057870db828d..960c11d75c12 100644 --- a/crates/polars-parquet/src/arrow/read/deserialize/utils/mod.rs +++ b/crates/polars-parquet/src/arrow/read/deserialize/utils/mod.rs @@ -43,7 +43,7 @@ impl<'a, D: Decoder> State<'a, D> { let mut page_validity = None; // Make the page_validity None if there are no nulls in the page - if is_optional && !page.null_count().is_some_and(|nc| nc == 0) { + if is_optional && page.null_count().is_none_or(|nc| nc != 0) { let pv = page_validity_decoder(page)?; let pv = decode_page_validity(pv, None)?; diff --git a/crates/polars-parquet/src/parquet/encoding/delta_byte_array/decoder.rs b/crates/polars-parquet/src/parquet/encoding/delta_byte_array/decoder.rs index 1d1b82e7cd49..bcdf9403b7be 100644 --- a/crates/polars-parquet/src/parquet/encoding/delta_byte_array/decoder.rs +++ b/crates/polars-parquet/src/parquet/encoding/delta_byte_array/decoder.rs @@ -52,7 +52,7 @@ impl<'a> Decoder<'a> { } } -impl<'a> Iterator for Decoder<'a> { +impl Iterator for Decoder<'_> { type Item = ParquetResult>; fn next(&mut self) -> Option { @@ -92,7 +92,7 @@ impl<'a> Iterator for Decoder<'a> { } } -impl<'a> ExactSizeIterator for Decoder<'a> {} +impl ExactSizeIterator for Decoder<'_> {} #[cfg(test)] mod tests { diff --git a/crates/polars-utils/src/chunks.rs b/crates/polars-utils/src/chunks.rs index 21fc37e99aff..80f720eb2fd7 100644 --- a/crates/polars-utils/src/chunks.rs +++ b/crates/polars-utils/src/chunks.rs @@ -25,7 +25,7 @@ impl<'a, T> Iterator for Chunks<'a, T> { } } -impl<'a, T> DoubleEndedIterator for Chunks<'a, T> { +impl DoubleEndedIterator for Chunks<'_, T> { fn next_back(&mut self) -> Option { if self.slice.is_empty() { return None; @@ -41,7 +41,7 @@ impl<'a, T> DoubleEndedIterator for Chunks<'a, T> { } } -impl<'a, T> ExactSizeIterator for Chunks<'a, T> {} +impl ExactSizeIterator for Chunks<'_, T> {} impl<'a, T> Chunks<'a, T> { pub const fn new(slice: &'a [T], chunk_size: usize) -> Self {