collect_partitioned

datafusion::physical_plan::execution_plan

Function collect_partitioned 

Source 
pub async fn collect_partitioned(
    plan: Arc<dyn ExecutionPlan>,
    context: Arc<TaskContext>,
) -> Result<Vec<Vec<RecordBatch>>, DataFusionError>
Expand description

Execute the ExecutionPlan and collect the results in memory