Function datafusion::physical_plan::execute_stream_partitioned
source · [−]pub async fn execute_stream_partitioned(
plan: Arc<dyn ExecutionPlan>,
context: Arc<TaskContext>
) -> Result<Vec<SendableRecordBatchStream>>Expand description
Execute the ExecutionPlan and return a vec with one stream per output partition