Function datafusion::physical_plan::collect

source · 
pub async fn collect(
    plan: Arc<dyn ExecutionPlan>,
    context: Arc<TaskContext>
) -> Result<Vec<RecordBatch>>
Expand description

Execute the ExecutionPlan and collect the results in memory