Struct MemoryControlPolicy 

pub struct MemoryControlPolicy {
    pub device_budget_bytes: u64,
    pub max_source_chunk_bytes: u64,
    pub max_row_groups_per_chunk: usize,
    pub max_retry_attempts: usize,
    pub min_retry_chunk_row_groups: usize,
}

The device budget and source chunking one execution runs under. An admitted attempt’s budget is its grant.

Fields

device_budget_bytes: u64

Allocation cap of the attempt. The runtime’s device ledger enforces it; planning only sizes chunks against it.

max_source_chunk_bytes: u64

Source-byte grouping target, compared with each chunk’s decoded size estimate (crate::chunk::decoded). u64::MAX leaves the configured target unset; source tasks derive a finite target from the admitted grant.

max_row_groups_per_chunk: usize

Row groups coalesced into one source chunk. The throughput planning mode may raise it to the row-group cap crate::chunk owns.

max_retry_attempts: usize

Attempts the engine’s retry may spend splitting one chunk after an allocation failure.

min_retry_chunk_row_groups: usize

Smallest chunk, in row groups, a retry may split down to.

Implementations

impl MemoryControlPolicy

pub const DEFAULT_MAX_SOURCE_CHUNK_BYTES: u64 = u64::MAX

No configured source-byte ceiling; the immutable grant sizes batches.

pub const DEFAULT_MAX_ROW_GROUPS_PER_CHUNK: usize = 1

One row group per chunk. The default throughput planning mode raises this cap for local Parquet sources; the conservative mode keeps it.

pub const DEFAULT_MAX_RETRY_ATTEMPTS: usize = 3

Default retry limit for splitting a source chunk after allocation failure.

pub const DEFAULT_MIN_RETRY_CHUNK_ROW_GROUPS: usize = 1

Default minimum retry chunk of one row group.

pub fn validate(self) -> Result<()>

Rejects a zero in any field; the error names the field in its field fact. Zero is not a “disabled” value here, since each field bounds a loop or a division in chunk planning.

Trait Implementations

impl Clone for MemoryControlPolicy

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 MemoryControlPolicy

impl Debug for MemoryControlPolicy

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

Formats the value using the given formatter.

impl Eq for MemoryControlPolicy

impl From<MemoryControlPolicy> for SourceChunkPlanningPolicy

fn from(memory_policy: MemoryControlPolicy) -> Self

Converts to this type from the input type.

impl Hash for MemoryControlPolicy

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for MemoryControlPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for MemoryControlPolicy