datafusion::physical_plan

Function collect

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

Execute the ExecutionPlan and collect the results in memory