execute_query_streaming

Function execute_query_streaming 

Source
pub fn execute_query_streaming<'txn, S: KVStore + 'txn, C: Catalog, T: SqlTxn<'txn, S>>(
    txn: &mut T,
    catalog: &C,
    plan: LogicalPlan,
) -> Result<QueryRowIterator<'static>>
Expand description

Execute a SELECT logical plan and return a streaming query result.

This function returns a QueryRowIterator that yields rows one at a time, enabling true streaming output without materializing all rows upfront.

§FR-7 Streaming Output

This function implements the FR-7 requirement for streaming output. Rows are yielded through an iterator interface, and projection is applied on-the-fly as each row is consumed.

§Note

KNN queries currently fall back to the non-streaming path as they require specialized handling.