Skip to content

Commit d60d918

Browse files
adriangbetseidl
andcommitted
more rusty
Co-authored-by: Ed Seidl <etseidl@users.noreply.github.com>
1 parent 60f6110 commit d60d918

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

parquet/src/file/page_index/index.rs

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -227,16 +227,17 @@ impl<T: ParquetValueType> NativeIndex<T> {
227227
}
228228

229229
pub(crate) fn to_thrift(&self) -> ColumnIndex {
230-
let mut min_values = vec![vec![]; self.indexes.len()];
231-
let mut max_values = vec![vec![]; self.indexes.len()];
232-
for (i, index) in self.indexes.iter().enumerate() {
233-
if let Some(min) = index.min_bytes() {
234-
min_values[i].extend_from_slice(min);
235-
}
236-
if let Some(max) = index.max_bytes() {
237-
max_values[i].extend_from_slice(max);
238-
}
239-
}
230+
let min_values = self
231+
.indexes
232+
.iter()
233+
.map(|x| x.min_bytes().unwrap_or(&[]).to_vec())
234+
.collect::<Vec<_>>();
235+
236+
let max_values = self
237+
.indexes
238+
.iter()
239+
.map(|x| x.max_bytes().unwrap_or(&[]).to_vec())
240+
.collect::<Vec<_>>();
240241

241242
let null_counts = self
242243
.indexes

0 commit comments

Comments
 (0)