Skip to content

Commit d5173db

Browse files
committed
fix rustfmt issues
1 parent 9ebf874 commit d5173db

File tree

8 files changed

+869
-415
lines changed

8 files changed

+869
-415
lines changed

arrow/src/array/transform/mod.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ use std::mem;
2525

2626
use super::{
2727
data::{into_buffers, new_buffers},
28-
ArrayData, ArrayDataBuilder
28+
ArrayData, ArrayDataBuilder,
2929
};
3030
use crate::array::StringOffsetSizeTrait;
3131

@@ -84,7 +84,8 @@ impl<'a> _MutableArrayData<'a> {
8484
.buffers(buffers)
8585
.child_data(child_data);
8686
if self.null_count > 0 {
87-
array_data_builder = array_data_builder.null_bit_buffer(self.null_buffer.into());
87+
array_data_builder =
88+
array_data_builder.null_bit_buffer(self.null_buffer.into());
8889
}
8990

9091
array_data_builder
@@ -554,8 +555,7 @@ impl<'a> MutableArrayData<'a> {
554555
let null_buffer = if use_nulls {
555556
let null_bytes = bit_util::ceil(array_capacity, 8);
556557
MutableBuffer::from_len_zeroed(null_bytes)
557-
}
558-
else {
558+
} else {
559559
// create 0 capacity mutable buffer with the intention that it won't be used
560560
MutableBuffer::with_capacity(0)
561561
};

parquet/benches/arrow_array_reader.rs

Lines changed: 432 additions & 153 deletions
Large diffs are not rendered by default.

parquet/src/arrow/array_reader.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1499,7 +1499,9 @@ impl<'a> ArrayReaderBuilder {
14991499
arrow_type,
15001500
)?))
15011501
} else {
1502-
use crate::arrow::arrow_array_reader::{StringArrayConverter, ArrowArrayReader};
1502+
use crate::arrow::arrow_array_reader::{
1503+
ArrowArrayReader, StringArrayConverter,
1504+
};
15031505
let converter = StringArrayConverter::new();
15041506
Ok(Box::new(ArrowArrayReader::try_new(
15051507
*page_iterator,

parquet/src/arrow/arrow_array_reader.rs

Lines changed: 422 additions & 251 deletions
Large diffs are not rendered by default.

parquet/src/arrow/record_reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -466,7 +466,7 @@ mod tests {
466466

467467
impl Iterator for TestPageReader {
468468
type Item = Result<Page>;
469-
469+
470470
fn next(&mut self) -> Option<Self::Item> {
471471
self.get_next_page().transpose()
472472
}

parquet/src/column/reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1356,7 +1356,7 @@ mod tests {
13561356

13571357
impl Iterator for TestPageReader {
13581358
type Item = Result<Page>;
1359-
1359+
13601360
fn next(&mut self) -> Option<Self::Item> {
13611361
self.get_next_page().transpose()
13621362
}

parquet/src/util/mod.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,4 +23,6 @@ mod bit_packing;
2323
pub mod cursor;
2424
pub mod hash_util;
2525
pub(crate) mod test_common;
26-
pub use self::test_common::page_util::{InMemoryPageIterator, DataPageBuilderImpl, DataPageBuilder};
26+
pub use self::test_common::page_util::{
27+
DataPageBuilder, DataPageBuilderImpl, InMemoryPageIterator,
28+
};

parquet/src/util/test_common/page_util.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -217,9 +217,9 @@ impl<I: Iterator<Item = Vec<Page>>> Iterator for InMemoryPageIterator<I> {
217217
type Item = Result<Box<dyn PageReader>>;
218218

219219
fn next(&mut self) -> Option<Self::Item> {
220-
self.page_reader_iter.next().map(
221-
|x| Ok(Box::new(InMemoryPageReader::new(x)) as Box<dyn PageReader>)
222-
)
220+
self.page_reader_iter
221+
.next()
222+
.map(|x| Ok(Box::new(InMemoryPageReader::new(x)) as Box<dyn PageReader>))
223223
}
224224
}
225225

0 commit comments

Comments
 (0)