Function datafusion_physical_plan::execute_stream

pub fn execute_stream(
    plan: Arc<dyn ExecutionPlan>,
    context: Arc<TaskContext>,
) -> Result<SendableRecordBatchStream>

Execute the ExecutionPlan and return a single stream of RecordBatches.

See collect to buffer the RecordBatches in memory.

Aborting Execution

Dropping the stream will abort the execution of the query, and free up any allocated resources