Skip to content

Commit 332a795

Browse files
committed
chore: cargo fmt and clippy
1 parent e9b557d commit 332a795

File tree

2 files changed

+13
-6
lines changed

2 files changed

+13
-6
lines changed

crates/iceberg/src/arrow/nan_val_cnt_visitor.rs

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ macro_rules! cast_and_update_cnt_map {
3131
v.insert(nan_val_cnt);
3232
}
3333
};
34-
}
34+
};
3535
}
3636

3737
macro_rules! count_float_nans {
@@ -141,7 +141,7 @@ impl NanValueCountVisitor {
141141

142142
let struct_arr = Arc::new(StructArray::from(batch)) as ArrayRef;
143143
visit_struct_with_partner(
144-
&schema.as_struct(),
144+
schema.as_struct(),
145145
&struct_arr,
146146
self,
147147
&arrow_arr_partner_accessor,
@@ -150,3 +150,9 @@ impl NanValueCountVisitor {
150150
Ok(())
151151
}
152152
}
153+
154+
impl Default for NanValueCountVisitor {
155+
fn default() -> Self {
156+
Self::new()
157+
}
158+
}

crates/iceberg/src/writer/file_writer/parquet_writer.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ use super::track_writer::TrackWriter;
3838
use super::{FileWriter, FileWriterBuilder};
3939
use crate::arrow::{
4040
get_parquet_stat_max_as_datum, get_parquet_stat_min_as_datum, ArrowFileReader,
41-
DEFAULT_MAP_FIELD_NAME, NanValueCountVisitor,
41+
NanValueCountVisitor, DEFAULT_MAP_FIELD_NAME,
4242
};
4343
use crate::io::{FileIO, FileWrite, OutputFile};
4444
use crate::spec::{
@@ -524,7 +524,8 @@ impl FileWriter for ParquetWriter {
524524
self.current_row_num += batch.num_rows();
525525

526526
let batch_c = batch.clone();
527-
self.nan_value_count_visitor.compute(self.schema.clone(), batch_c)?;
527+
self.nan_value_count_visitor
528+
.compute(self.schema.clone(), batch_c)?;
528529

529530
// Lazy initialize the writer
530531
let writer = if let Some(writer) = &mut self.inner_writer {
@@ -635,8 +636,8 @@ mod tests {
635636
use arrow_array::builder::{Float32Builder, Int32Builder, MapBuilder};
636637
use arrow_array::types::{Float32Type, Int64Type};
637638
use arrow_array::{
638-
Array, ArrayRef, BooleanArray, Decimal128Array, Float32Array, Int32Array, Int64Array,
639-
ListArray, RecordBatch, StructArray, MapArray, Float64Array,
639+
Array, ArrayRef, BooleanArray, Decimal128Array, Float32Array, Float64Array, Int32Array,
640+
Int64Array, ListArray, MapArray, RecordBatch, StructArray,
640641
};
641642
use arrow_schema::{DataType, Field, Fields, SchemaRef as ArrowSchemaRef};
642643
use arrow_select::concat::concat_batches;

0 commit comments

Comments
 (0)