Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Clippy
  • Loading branch information
progval committed Jun 13, 2024
commit e4a588da7a772556719917238ff377e01a740282
25 changes: 11 additions & 14 deletions parquet/src/file/writer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -450,20 +450,17 @@ fn write_bloom_filters<W: Write + Send>(
.expect("Negative row group ordinal");
let row_group_idx = row_group_idx as usize;
for (column_idx, column_chunk) in row_group.columns_mut().iter_mut().enumerate() {
match bloom_filters[row_group_idx][column_idx].take() {
Some(bloom_filter) => {
let start_offset = buf.bytes_written();
bloom_filter.write(&mut *buf)?;
let end_offset = buf.bytes_written();
// set offset and index for bloom filter
*column_chunk = column_chunk
.clone()
.into_builder()
.set_bloom_filter_offset(Some(start_offset as i64))
.set_bloom_filter_length(Some((end_offset - start_offset) as i32))
.build()?;
}
None => {}
if let Some(bloom_filter) = bloom_filters[row_group_idx][column_idx].take() {
let start_offset = buf.bytes_written();
bloom_filter.write(&mut *buf)?;
let end_offset = buf.bytes_written();
// set offset and index for bloom filter
*column_chunk = column_chunk
.clone()
.into_builder()
.set_bloom_filter_offset(Some(start_offset as i64))
.set_bloom_filter_length(Some((end_offset - start_offset) as i32))
.build()?;
}
}
Ok(())
Expand Down