Struct RowSetFinishingIncremental

pub struct RowSetFinishingIncremental {
    pub remaining_limit: Option<usize>,
    pub remaining_offset: usize,
    pub max_returned_query_size: Option<u64>,
    pub remaining_max_returned_query_size: Option<u64>,
    pub project: Vec<usize>,
}

A RowSetFinishing that can be repeatedly applied to batches of updates (in a RowCollection) and keeps track of the remaining limit, offset, and cap on query result size.

Fields

remaining_limit: Option<usize>

Include only as many rows (after offset).

remaining_offset: usize

Omit as many rows.

max_returned_query_size: Option<u64>

The maximum allowed result size, as requested by the client.

remaining_max_returned_query_size: Option<u64>

Tracks our remaining allowed budget for result size.

project: Vec<usize>

Include only given columns.

Implementations

impl RowSetFinishingIncremental

pub fn new( offset: usize, limit: Option<NonNeg<i64>>, project: Vec<usize>, max_returned_query_size: Option<u64>, ) -> Self

Turns the given RowSetFinishing into a RowSetFinishingIncremental. Can only be used when is_streamable is true.

Panics

Panics if the result is not streamable, that is it has an ORDER BY.

pub fn finish_incremental( &mut self, rows: RowCollection, max_result_size: u64, duration_histogram: &Histogram, ) -> Result<SortedRowCollectionIter, String>

Applies finishing actions to the given RowCollection, and reports the total time it took to run.

Returns a SortedRowCollectionIter that contains all of the response data.

fn finish_incremental_inner( &mut self, rows: RowCollection, max_result_size: u64, ) -> Result<SortedRowCollectionIter, String>

Trait Implementations

impl Debug for RowSetFinishingIncremental

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.