pub async fn collect(&self, physical_plan: Arc<dyn ExecutionPlan>) -> Result<Vec<RecordBatch>> {
        debug!(
            "Running plan, physical:\n{}",
            displayable(physical_plan.as_ref()).indent()
        );

        self.exec.spawn(collect(physical_plan)).await.map_err(|e| {
            Error::Execution(format!("Error running IOxExecutionContext::collect: {}", e))
        })?
    }
/// Executes the logical plan using DataFusion on a separate
/// thread pool and produces RecordBatches
Executes the logical plan using DataFusion on a separate
thread pool and produces RecordBatches
Executes the logical plan using DataFusion on a separate thread pool and produces RecordBatches
pub async fn collect(&self, physical_plan: Arc<dyn ExecutionPlan>) -> Result<Vec<RecordBatch>> {
        debug!(
            "Running plan, physical:\n{}",
            displayable(physical_plan.as_ref()).indent()
        );
        self.exec.spawn(collect(physical_plan)).await.map_err(|e| {
            Error::Execution(format!("Error running IOxExecutionContext::collect: {}", e))
        })?
    }
pub async fn collect ( & self , physical_plan : Arc < dyn ExecutionPlan > ) -> Result < Vec < RecordBatch > > { debug ! ( " \n " displayable ( physical_plan as_ref ( ) ) indent ( ) ) ; self . exec . spawn ( collect ( physical_plan ) ) . await . map_err ( | e | { Error :: Execution ( format ! ( " " e ) ) } ) ? }
Executes the logical plan using DataFusion on a separate
thread pool and produces RecordBatches
Executes the logical plan using DataFusion on a separate thread pool and produces RecordBatches
&self
physical_plan
Arc<dyn ExecutionPlan>
&self
physical_plan
Arc<dyn ExecutionPlan>