Struct QueryOptions 

pub struct QueryOptions {
    pub target_partitions: Option<usize>,
    pub output_batch_size: Option<usize>,
}

Query execution options applied before DataFusion planning and execution.

Fields

target_partitions: Option<usize>

Optional DataFusion execution partition target.

When set, this is passed to DataFusion as the session target partition count before query planning. When unset, DataFusion’s session default remains in effect. Provider scans treat the DataFusion target as a cap while deriving their own conservative physical scan partition target; automatic scan-wide read capacity is resolved from that derived target.

output_batch_size: Option<usize>

Optional DataFusion execution batch size.

This is an upstream query-engine batch-size request. Arbitrary DataFusion operators may still produce smaller or differently shaped final output batches.

Implementations

impl QueryOptions

pub fn validate(&self) -> Result<(), DeltaFunnelError>

Validates query options before any source reads or target side effects.

Errors

Returns DeltaFunnelError::BatchPipeline when a configured numeric option is zero.

pub fn apply_to_session_config( &self, config: SessionConfig, ) -> Result<SessionConfig, DeltaFunnelError>

Applies validated query options to a DataFusion session config.

Errors

Returns DeltaFunnelError::BatchPipeline when validation fails.

Trait Implementations

impl Clone for QueryOptions

fn clone(&self) -> QueryOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for QueryOptions

impl Debug for QueryOptions

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

Formats the value using the given formatter.

impl Default for QueryOptions

fn default() -> QueryOptions

Returns the “default value” for a type.

impl Eq for QueryOptions

impl PartialEq for QueryOptions

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for QueryOptions