Trait PhysicalPipedExpr

pub trait PhysicalPipedExpr:
    PhysicalIoExpr
    + Send
    + Sync {
    // Required methods
    fn evaluate(
        &self,
        chunk: &DataChunk,
        lazy_state: &ExecutionState,
    ) -> PolarsResult<Series>;
    fn field(&self, input_schema: &Schema) -> PolarsResult<Field>;
    fn expression(&self) -> Expr;
}

Required Methods

fn evaluate( &self, chunk: &DataChunk, lazy_state: &ExecutionState, ) -> PolarsResult<Series>

Take a DataFrame and produces a boolean Series that serves as a predicate mask

fn field(&self, input_schema: &Schema) -> PolarsResult<Field>

fn expression(&self) -> Expr

Implementors