Module filter 

Re-exports

use crate::arrow::ProjectionMask; 🔒

use crate::arrow::arrow_reader::RowSelection; 🔒

use crate::arrow::arrow_reader::RowSelectionPolicy; 🔒

use crate::schema::types::SchemaDescriptor; 🔒

use arrow_array::Array; 🔒

use arrow_array::BooleanArray; 🔒

use arrow_array::RecordBatch; 🔒

use arrow_buffer::BooleanBuffer; 🔒

use arrow_schema::ArrowError; 🔒

use arrow_select::filter::SlicesIterator; 🔒

use arrow_select::filter::filter_record_batch; 🔒

use arrow_select::filter::prep_null_mask_filter; 🔒

use std::fmt::Debug; 🔒

use std::fmt::Debug; 🔒

use std::fmt::Formatter; 🔒

Structs

ArrowPredicateFn

An ArrowPredicate created from an FnMut and a ProjectionMask

FusedPredicate 🔒

Evaluate same-projection predicates in order on one decoded batch. Later predicates see only surviving rows, sliced when contiguous or compacted otherwise.

RowFilter

Filter applied during the parquet read process

Traits

ArrowPredicate

A predicate operating on [RecordBatch]

Functions

can_fuse_projection 🔒

Restrict fusion to one top-level, non-repeated leaf to limit compaction costs.

evaluate_predicate 🔒

Validate the predicate result length and treat nulls as false.

narrow_batch 🔒

Restrict batch to the rows filter accepts, slicing zero-copy when they form one contiguous range and compacting otherwise.