Struct SourceChunking 

pub struct SourceChunking {
    pub max_source_chunk_bytes: NonZeroU64,
    pub max_row_groups_per_chunk: NonZeroUsize,
    pub max_retry_attempts: NonZeroUsize,
    pub min_retry_chunk_row_groups: NonZeroUsize,
}

Source chunking of native reads. Device capacity always comes from the admitted grant, so a chunking carries no device budget.

Fields

max_source_chunk_bytes: NonZeroU64

Source bytes planned into one chunk; a planning target. u64::MAX derives the target from the immutable admitted grant.

max_row_groups_per_chunk: NonZeroUsize

Row groups planned into one chunk.

max_retry_attempts: NonZeroUsize

Attempts a failed chunk read retries with smaller chunks.

min_retry_chunk_row_groups: NonZeroUsize

Row-group floor of a retried chunk.

Implementations

impl SourceChunking

pub const DEFAULT_MAX_SOURCE_CHUNK_BYTES: NonZeroU64

Default source-byte setting, without a configured ceiling.

pub const DEFAULT_MAX_ROW_GROUPS_PER_CHUNK: NonZeroUsize

Default row groups planned into one chunk.

pub const DEFAULT_MAX_RETRY_ATTEMPTS: NonZeroUsize

Default retry attempts of a failed chunk read.

pub const DEFAULT_MIN_RETRY_CHUNK_ROW_GROUPS: NonZeroUsize

Default row-group floor of a retried chunk.

pub fn explicit_max_source_chunk_bytes(&self) -> Option<NonZeroU64>

The configured source-byte ceiling, or None when the default leaves the target to the admitted grant.

pub fn try_new( max_source_chunk_bytes: u64, max_row_groups_per_chunk: usize, max_retry_attempts: usize, min_retry_chunk_row_groups: usize, ) -> Result<Self>

Chunking from plain counts; each must be greater than zero.

Trait Implementations

impl Clone for SourceChunking

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SourceChunking

impl Debug for SourceChunking

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

Formats the value using the given formatter.

impl Default for SourceChunking

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SourceChunking

impl PartialEq for SourceChunking

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceChunking