This is an automated email from the ASF dual-hosted git repository.
mbutrovich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 440f5581a chore: Fix clippy complaints (#3634)
440f5581a is described below
commit 440f5581a8a6881a8c74170a05264c8477d720ff
Author: Oleks V <[email protected]>
AuthorDate: Thu Mar 5 19:08:35 2026 -0800
chore: Fix clippy complaints (#3634)
---
native/core/benches/parquet_read.rs | 3 +--
native/core/src/parquet/util/test_common/page_util.rs | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/native/core/benches/parquet_read.rs
b/native/core/benches/parquet_read.rs
index a56c748e0..52ab96eb1 100644
--- a/native/core/benches/parquet_read.rs
+++ b/native/core/benches/parquet_read.rs
@@ -37,7 +37,6 @@ use comet::parquet::util::test_common::page_util::{
use perf::FlamegraphProfiler;
use rand::{prelude::StdRng, RngExt, SeedableRng};
-use zstd::zstd_safe::WriteBuf;
fn bench(c: &mut Criterion) {
let expected_num_values: usize = NUM_PAGES * VALUES_PER_PAGE;
@@ -177,7 +176,7 @@ impl TestColumnReader {
fn load_page(&mut self) {
if let Some(page) = self.pages.get_next_page().unwrap() {
let num_values = page.num_values() as usize;
- let buffer = Buffer::from_slice_ref(page.buffer().as_slice());
+ let buffer = Buffer::from_slice_ref(page.buffer());
self.inner.set_page_v1(num_values, buffer, page.encoding());
}
}
diff --git a/native/core/src/parquet/util/test_common/page_util.rs
b/native/core/src/parquet/util/test_common/page_util.rs
index e4e3e30c4..6bda2db31 100644
--- a/native/core/src/parquet/util/test_common/page_util.rs
+++ b/native/core/src/parquet/util/test_common/page_util.rs
@@ -33,7 +33,6 @@ use parquet::{
use super::random_numbers_range;
use bytes::Bytes;
-use zstd::zstd_safe::WriteBuf;
pub trait DataPageBuilder {
fn add_rep_levels(&mut self, max_level: i16, rep_levels: &[i16]);
@@ -127,7 +126,7 @@ impl DataPageBuilder for DataPageBuilderImpl {
let encoded_values = encoder
.flush_buffer()
.expect("consume_buffer() should be OK");
- self.buffer.extend_from_slice(encoded_values.as_slice());
+ self.buffer.extend_from_slice(&encoded_values);
}
fn add_indices(&mut self, indices: Bytes) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
