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
pub async fn collect(
plan: Arc<dyn ExecutionPlan>,
context: Arc<TaskContext>,
) -> Result<Vec<RecordBatch>, DataFusionError>Execute the ExecutionPlan and collect the results in memory