Struct LiquidPredicate 

pub struct LiquidPredicate { /* private fields */ }

A “compiled” predicate passed to ParquetRecordBatchStream to perform row-level filtering during parquet decoding.

See the module level documentation for more information.

Implements the ArrowPredicate trait used by the parquet decoder

An expression can be evaluated as a DatafusionArrowPredicate if it:

• Does not reference any projected columns
• Does not reference columns with non-primitive types (e.g. structs / lists)

Implementations

impl LiquidPredicate

pub fn try_new_with_metrics( candidate: FilterCandidate, projection: ProjectionMask, rows_pruned: Count, rows_matched: Count, time: Time, ) -> Result<Self>

Create a new LiquidPredicate from a FilterCandidate

pub fn try_new( candidate: FilterCandidate, projection: ProjectionMask, ) -> Result<Self>

Create a new LiquidPredicate from a FilterCandidate

pub fn physical_expr_physical_column_index(&self) -> &Arc<dyn PhysicalExpr>

Get the physical expression with physical column index.

pub fn predicate_column_ids(&self) -> Vec<usize>

Get the column ids of the predicate.

Trait Implementations

impl ArrowPredicate for LiquidPredicate

fn projection(&self) -> &ProjectionMask

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

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

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

impl Clone for LiquidPredicate

fn clone(&self) -> LiquidPredicate

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LiquidPredicate

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

Formats the value using the given formatter.

impl Display for LiquidPredicate

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

Formats the value using the given formatter.