Struct ProjectionPlan

pub struct ProjectionPlan {
    pub physical_schema: Arc<Schema>,
    pub physical_df_schema: Arc<DFSchema>,
    pub sibling_schema: Option<Arc<Schema>>,
    pub requested_output_expr: Option<Vec<(Expr, String)>>,
}

Fields

physical_schema: Arc<Schema>

The physical schema (before dynamic projection) that must be loaded from the dataset

physical_df_schema: Arc<DFSchema>

sibling_schema: Option<Arc<Schema>>

The schema of the sibling fields that must be loaded

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

The expressions for all the columns to be in the output Note: this doesn’t include _distance, and _rowid

Implementations

impl ProjectionPlan

pub fn try_new( base_schema: &Schema, columns: &[(impl AsRef<str>, impl AsRef<str>)], load_blobs: bool, ) -> Result<Self>

pub fn new_empty(base_schema: Arc<Schema>, load_blobs: bool) -> Self

pub fn inner_new( base_schema: Arc<Schema>, load_blobs: bool, sibling_schema: Option<Arc<Schema>>, ) -> Self

pub fn arrow_schema(&self) -> &ArrowSchema

pub fn arrow_schema_ref(&self) -> SchemaRef

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

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

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

pub fn project_stream( &self, stream: SendableRecordBatchStream, ) -> Result<SendableRecordBatchStream>

Trait Implementations

impl Debug for ProjectionPlan

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

Formats the value using the given formatter.