pub async fn execute_partition(
        &self,
        physical_plan: Arc<dyn ExecutionPlan>,
        partition: usize,
    ) -> Result<SendableRecordBatchStream> {
        self.exec
            .spawn(async move { physical_plan.execute(partition).await })
            .await
            .map_err(|e| {
                Error::Execution(format!("Error running IOxExecutionContext::execute: {}", e))
            })?
    }
/// Executes a single partition of a physical plan and produces a RecordBatchStream to stream
/// over the result that iterates over the results.
Executes a single partition of a physical plan and produces a RecordBatchStream to stream
over the result that iterates over the results.
Executes a single partition of a physical plan and produces a RecordBatchStream to stream over the result that iterates over the results .
pub async fn execute_partition(
        &self,
        physical_plan: Arc<dyn ExecutionPlan>,
        partition: usize,
    ) -> Result<SendableRecordBatchStream> {
        self.exec
            .spawn(async move { physical_plan.execute(partition).await })
            .await
            .map_err(|e| {
                Error::Execution(format!("Error running IOxExecutionContext::execute: {}", e))
            })?
    }
pub async fn execute_partition ( & self , physical_plan : Arc < dyn ExecutionPlan > , partition : usize , ) -> Result < SendableRecordBatchStream > { self . exec . spawn ( async move { physical_plan . execute ( partition ) . await } ) . await . map_err ( | e | { Error :: Execution ( format ! ( " " e ) ) } ) ? }
Executes a single partition of a physical plan and produces a RecordBatchStream to stream
over the result that iterates over the results.
Executes a single partition of a physical plan and produces a RecordBatchStream to stream over the result that iterates over the results .
&self
physical_plan
Arc<dyn ExecutionPlan>
partition
usize
&self
physical_plan
Arc<dyn ExecutionPlan>
partition
usize