Skip to content

Commit

Permalink
refactor(rust): Fix new-streaming test_lazy_parquet::test_row_index (
Browse files Browse the repository at this point in the history
  • Loading branch information
nameexhaustion authored Sep 27, 2024
1 parent a7432b9 commit 89fd285
Showing 1 changed file with 8 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -645,11 +645,15 @@ fn decode_column_prefiltered(

let column = Series::try_from((arrow_field, array))?.into_column();

if !prefilter {
column.filter(mask)
let column = if !prefilter {
column.filter(mask)?
} else {
Ok(column)
}
column
};

assert_eq!(column.len(), expected_num_rows);

Ok(column)
}

mod tests {
Expand Down

0 comments on commit 89fd285

Please sign in to comment.