pub async fn execute(
        &self,
        physical_plan: Arc<dyn ExecutionPlan>,
    ) -> Result<SendableRecordBatchStream> {
        match physical_plan.output_partitioning().partition_count() {
            0 => unreachable!(),
            1 => self.execute_partition(physical_plan, 0).await,
            _ => {
                // Merge into a single partition
                self.execute_partition(Arc::new(CoalescePartitionsExec::new(physical_plan)), 0)
                    .await
            }
        }
    }
/// Executes the physical plan and produces a RecordBatchStream to stream
/// over the result that iterates over the results.
Executes the physical plan and produces a RecordBatchStream to stream
over the result that iterates over the results.
Executes the physical plan and produces a RecordBatchStream to stream over the result that iterates over the results .
pub async fn execute(
        &self,
        physical_plan: Arc<dyn ExecutionPlan>,
    ) -> Result<SendableRecordBatchStream> {
        match physical_plan.output_partitioning().partition_count() {
            0 => unreachable!(),
            1 => self.execute_partition(physical_plan, 0).await,
            _ => {
                // Merge into a single partition
                self.execute_partition(Arc::new(CoalescePartitionsExec::new(physical_plan)), 0)
                    .await
            }
        }
    }
pub async fn execute ( & self , physical_plan : Arc < dyn ExecutionPlan > , ) -> Result < SendableRecordBatchStream > { match physical_plan . output_partitioning ( ) . partition_count ( ) { 0 => unreachable ! ( ) , 1 => self . execute_partition ( physical_plan , 0 ) . await , _ => { // Merge into a single partition self . execute_partition ( Arc :: new ( CoalescePartitionsExec :: new ( physical_plan ) ) , 0 ) . await } } }
Executes the physical plan and produces a RecordBatchStream to stream
over the result that iterates over the results.
Executes the physical plan and produces a RecordBatchStream to stream over the result that iterates over the results .
&self
physical_plan
Arc<dyn ExecutionPlan>
&self
physical_plan
Arc<dyn ExecutionPlan>