Function collect_partitioned

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

Execute the ExecutionPlan and collect the results in memory