Skip to content

Commit f8fe7ba

Browse files
committed
fix: remove unused import and mut in benchmark
1 parent bbe2da7 commit f8fe7ba

1 file changed

Lines changed: 4 additions & 10 deletions

File tree

native/core/benches/struct_conversion.rs

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ use comet::execution::shuffle::row::{
2626
};
2727
use comet::execution::shuffle::CompressionCodec;
2828
use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion};
29-
use std::sync::Arc;
3029
use tempfile::Builder;
3130

3231
const BATCH_SIZE: usize = 5000;
@@ -103,7 +102,7 @@ fn benchmark_struct_conversion(c: &mut Criterion) {
103102
// Create row data
104103
let rows: Vec<RowData> = (0..num_rows).map(|_| RowData::new(num_fields)).collect();
105104

106-
let mut spark_rows: Vec<SparkUnsafeRow> = rows
105+
let spark_rows: Vec<SparkUnsafeRow> = rows
107106
.iter()
108107
.map(|row_data| {
109108
let mut spark_row = SparkUnsafeRow::new_with_num_fields(1);
@@ -114,14 +113,9 @@ fn benchmark_struct_conversion(c: &mut Criterion) {
114113
})
115114
.collect();
116115

117-
let mut row_addresses: Vec<i64> = spark_rows
118-
.iter()
119-
.map(|row| row.get_row_addr())
120-
.collect();
121-
let mut row_sizes: Vec<i32> = spark_rows
122-
.iter()
123-
.map(|row| row.get_row_size())
124-
.collect();
116+
let mut row_addresses: Vec<i64> =
117+
spark_rows.iter().map(|row| row.get_row_addr()).collect();
118+
let mut row_sizes: Vec<i32> = spark_rows.iter().map(|row| row.get_row_size()).collect();
125119

126120
let row_address_ptr = row_addresses.as_mut_ptr();
127121
let row_size_ptr = row_sizes.as_mut_ptr();

0 commit comments

Comments
 (0)