Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
more bugs
Browse files Browse the repository at this point in the history
  • Loading branch information
danburkert committed Jan 26, 2022
1 parent 573b1c4 commit 542b4e9
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions src/io/parquet/read/binary/basic.rs
Original file line number Diff line number Diff line change
Expand Up @@ -105,8 +105,6 @@ fn read_delta_optional<O: Offset>(
values: &mut Binary<O>,
validity: &mut MutableBitmap,
) {
let length = values.len() + additional;

let Binary {
offsets,
values,
Expand All @@ -126,7 +124,7 @@ fn read_delta_optional<O: Offset>(
extend_from_decoder(
validity,
&mut validity_iterator,
length,
additional,
&mut Offsets::<O>(offsets),
offsets_iterator,
);
Expand All @@ -143,8 +141,6 @@ fn read_plain_optional<O: Offset>(
values: &mut Binary<O>,
validity: &mut MutableBitmap,
) {
let length = values.len() + additional;

// values_buffer: first 4 bytes are len, remaining is values
let values_iterator = utils::BinaryIter::new(values_buffer);

Expand All @@ -153,7 +149,7 @@ fn read_plain_optional<O: Offset>(
extend_from_decoder(
validity,
&mut validity_iterator,
length,
additional,
values,
values_iterator,
)
Expand Down

0 comments on commit 542b4e9

Please sign in to comment.