Struct DeltaProviderSchedulingReport 

pub struct DeltaProviderSchedulingReport { /* private fields */ }

Configured provider scheduling options included with a Delta source report.

Implementations

impl DeltaProviderSchedulingReport

pub const fn query_target_partitions(&self) -> Option<u64>

Returns the configured DataFusion target partition count, when set.

pub const fn reader_backend(&self) -> DeltaProviderReaderBackend

Returns the provider reader backend configured for source scans.

pub const fn max_concurrent_file_reads_per_scan(&self) -> Option<u64>

Returns the configured scan-wide file-read concurrency cap.

None means the cap is resolved during physical scan planning from the derived scan partition target and the configured per-partition cap.

pub const fn max_concurrent_file_reads_per_partition(&self) -> u64

Returns the configured per-partition file-read concurrency cap.

pub const fn output_buffer_capacity_per_partition(&self) -> u64

Returns the configured per-partition provider output buffer capacity.

pub const fn native_async_prefetch_file_count_per_partition(&self) -> u64

Returns the native async prefetch depth per execution partition.

Trait Implementations

impl Clone for DeltaProviderSchedulingReport

fn clone(&self) -> DeltaProviderSchedulingReport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DeltaProviderSchedulingReport

impl Debug for DeltaProviderSchedulingReport

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

Formats the value using the given formatter.

impl Eq for DeltaProviderSchedulingReport

impl PartialEq for DeltaProviderSchedulingReport

fn eq(&self, other: &DeltaProviderSchedulingReport) -> 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 DeltaProviderSchedulingReport