Struct FusedPredicate 

struct FusedPredicate {
    predicates: Vec<Box<dyn ArrowPredicate>>,
    composition_policy: RowSelectionPolicy,
}

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

Fields

predicates: Vec<Box<dyn ArrowPredicate>>

At least two predicates, all with the same projection.

composition_policy: RowSelectionPolicy

Chooses how intermediate selections are composed. The output is always a [BooleanArray], so this is independent of the reader’s RowSelectionPolicy, which governs decoding.

Implementations

impl FusedPredicate

fn new(predicates: Vec<Box<dyn ArrowPredicate>>) -> Self

Create a fused predicate from at least two predicates that share one projection.

Trait Implementations

impl ArrowPredicate for FusedPredicate

fn projection(&self) -> &ProjectionMask

Returns the ProjectionMask that describes the columns required to evaluate this predicate.

fn evaluate(&mut self, batch: RecordBatch) -> Result<BooleanArray, ArrowError>

Evaluate this predicate for the given [RecordBatch] containing the columns identified by Self::projection

impl Debug for FusedPredicate

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.