Struct FragmentControl 

pub struct FragmentControl {
    pub control: ExecutionControl,
    pub max_spill_bytes: u64,
}

Cooperative per-fragment execution control: cancellation/deadline shared with the query’s ExecutionControl hierarchy plus the fragment’s spill allowance.

Fields

control: ExecutionControl

Cooperative cancellation handle (child of the query control, so a registry cancel fans out to every fragment).

max_spill_bytes: u64

Maximum spill allowance stamped by the planner (spec section 12.10).

Implementations

impl FragmentControl

pub fn begin_spill( &self, manager: &SpillManager, query_id: QueryId, ) -> Result<SpillSession, SpillError>

Open a core spill session for this fragment against manager, capped at Self::max_spill_bytes. Query operators that sort/join/aggregate under pressure call this instead of inventing a second spill path.

Trait Implementations

impl Clone for FragmentControl

fn clone(&self) -> FragmentControl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FragmentControl

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

Formats the value using the given formatter.