Struct lance_datafusion::projection::ProjectionPlan

pub struct ProjectionPlan {
    pub physical_schema: Arc<Schema>,
    pub physical_df_schema: Arc<DFSchema>,
    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>

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>)], ) -> Result<Self>

pub fn new_empty(base_schema: 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>