polars-plan 0.55.1

Lazy query engine for the Polars DataFrame library
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use polars_utils::python_function::PythonObject;
#[cfg(feature = "ir_serde")]
use serde::{Deserialize, Serialize};

use crate::plans::ExprIR;

// Predicate handed to a pyarrow python scan.
#[derive(Clone, Debug)]
#[cfg_attr(feature = "ir_serde", derive(Serialize, Deserialize))]
pub struct ArrowPredicate {
    pub predicate: ExprIR,
    pub pyarrow_predicate: PythonObject,
    /// Set when only some minterms of the original predicate could be converted
    /// to pyarrow; the engine then post-applies the original predicate after
    /// the scan.
    pub has_residual: bool,
}

impl PartialEq for ArrowPredicate {
    fn eq(&self, other: &Self) -> bool {
        self.predicate == other.predicate && self.has_residual == other.has_residual
    }
}