Struct ProjectionPlan

pub struct ProjectionPlan {
    pub physical_projection: Projection,
    pub requested_output_expr: Option<Vec<(Expr, String)>>,
    /* private fields */
}

Fields

physical_projection: Projection

The physical schema that must be loaded from the dataset

requested_output_expr: Option<Vec<(Expr, String)>>

If present, expressions that represent the output columns. These expressions run on the output of the physical projection.

If not present, the output is the physical projection.

Note: this doesn’t include _distance, and _rowid

Implementations

impl ProjectionPlan

pub fn new(base: Arc<dyn Projectable>) -> Self

Create a new projection plan which projects all columns and does not include any expressions

pub fn project_from_expressions( &mut self, columns: &[(impl AsRef<str>, impl AsRef<str>)], ) -> Result<()>

Set the projection from SQL expressions

pub fn project_from_schema(&mut self, projection: &Schema)

Set the projection from a schema

This plan will have no complex expressions

pub fn to_physical_exprs( &self, current_schema: &ArrowSchema, ) -> Result<Vec<(Arc<dyn PhysicalExpr>, String)>>

pub fn include_row_id(&mut self)

pub fn include_row_addr(&mut self)

pub fn output_schema(&self) -> Result<ArrowSchema>

pub async fn project_batch(&self, batch: RecordBatch) -> Result<RecordBatch>

Trait Implementations

impl Clone for ProjectionPlan

fn clone(&self) -> ProjectionPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProjectionPlan

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

Formats the value using the given formatter.