Struct StreamOptions 

pub struct StreamOptions {
    pub memory_limit_bytes: u64,
    pub max_in_flight_batches: NonZeroUsize,
    pub batch_rows: NonZeroUsize,
}

Options shared by bounded materialization and streaming execution.

Fields

memory_limit_bytes: u64

Maximum bytes owned by the execution pipeline at one time.

max_in_flight_batches: NonZeroUsize

Maximum number of pipeline-owned batches at one time.

batch_rows: NonZeroUsize

Requested source row cap. It never relaxes memory_limit_bytes.

Implementations

impl StreamOptions

pub fn new( memory_limit_bytes: u64, max_in_flight_batches: NonZeroUsize, batch_rows: NonZeroUsize, ) -> Self

Construct validated bounded-execution options.

Trait Implementations

impl Clone for StreamOptions

fn clone(&self) -> StreamOptions

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for StreamOptions

impl Debug for StreamOptions

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

Formats the value using the given formatter.

impl Default for StreamOptions

fn default() -> Self

Returns the “default value” for a type.

impl Eq for StreamOptions

impl PartialEq for StreamOptions

fn eq(&self, other: &StreamOptions) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamOptions