pub async fn collect(
        &self,
        physical_plan: Arc<dyn ExecutionPlan>,
        executor_type: ExecutorType,
    ) -> Result<Vec<RecordBatch>> {
        self.new_context(executor_type)
            .collect(physical_plan)
            .await
            .context(DataFusionExecution)
    }
/// 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>,
        executor_type: ExecutorType,
    ) -> Result<Vec<RecordBatch>> {
        self.new_context(executor_type)
            .collect(physical_plan)
            .await
            .context(DataFusionExecution)
    }
pub async fn collect ( & self , physical_plan : Arc < dyn ExecutionPlan > , executor_type : ExecutorType , ) -> Result < Vec < RecordBatch > > { self . new_context ( executor_type ) . collect ( physical_plan ) . await . context ( DataFusionExecution ) }
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>
executor_type
ExecutorType
&self
physical_plan
Arc<dyn ExecutionPlan>
executor_type
ExecutorType