Function datafusion::physical_plan::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