ExecutionConfig

Struct ExecutionConfig 

Source
pub struct ExecutionConfig {
    pub max_batch_size: usize,
    pub collect_stats: bool,
    pub memory_limit: usize,
    pub max_rows_in_memory: usize,
}
Expand description

Configuration options for query execution.

Fields§

§max_batch_size: usize

Maximum number of rows to buffer in memory.

§collect_stats: bool

Whether to collect detailed statistics.

§memory_limit: usize

Memory limit in bytes (0 for no limit).

§max_rows_in_memory: usize

Maximum number of rows that operators can materialize in memory.

This limit applies to blocking operators like sort, join, and aggregate that need to collect rows before producing output. When an operator exceeds this limit, it returns a QueryTooLarge error.

Set to 0 to disable the limit (not recommended for production). Default: 1,000,000 rows.

Implementations§

Source§

impl ExecutionConfig

Source

pub const fn new() -> Self

Creates a new configuration with defaults.

Source

pub const fn with_batch_size(self, size: usize) -> Self

Sets the maximum batch size.

Source

pub const fn with_stats(self) -> Self

Enables statistics collection.

Source

pub const fn with_memory_limit(self, limit: usize) -> Self

Sets the memory limit.

Source

pub const fn with_max_rows_in_memory(self, limit: usize) -> Self

Sets the maximum rows that can be materialized in memory.

This limit applies to blocking operators like sort, join, and aggregate. Set to 0 to disable the limit (not recommended for production).

Trait Implementations§

Source§

impl Clone for ExecutionConfig

Source§

fn clone(&self) -> ExecutionConfig

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for ExecutionConfig

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for ExecutionConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more