Function datafusion::physical_plan::execute_stream
source · pub fn execute_stream(
plan: Arc<dyn ExecutionPlan>,
context: Arc<TaskContext>
) -> Result<SendableRecordBatchStream>
Expand description
Execute the ExecutionPlan and return a single stream of results