Struct OperatorMemoryContext 

pub struct OperatorMemoryContext { /* private fields */ }

Memory context passed to pipeline operators for pressure-aware spill decisions.

Lightweight and Clone-able (two Arc references). Operators that support memory-aware spilling receive this at construction time. It provides access to the BufferManager for pressure queries and consumer registration, and to a per-query SpillManager for creating spill files.

Implementations

impl OperatorMemoryContext

pub fn new( buffer_manager: Arc<BufferManager>, spill_manager: Arc<SpillManager>, ) -> Self

Creates a new operator memory context.

pub fn pressure_level(&self) -> PressureLevel

Returns the current pressure level.

pub fn should_spill(&self) -> bool

Returns whether system pressure warrants spilling (High or Critical).

pub fn register_consumer(&self, consumer: Arc<dyn MemoryConsumer>)

Registers a memory consumer with the buffer manager.

pub fn unregister_consumer(&self, name: &str)

Unregisters a memory consumer by name.

pub fn buffer_manager(&self) -> &Arc<BufferManager>

Returns a reference to the buffer manager.

pub fn spill_manager(&self) -> &Arc<SpillManager>

Returns a reference to the spill manager.

Trait Implementations

impl Clone for OperatorMemoryContext

fn clone(&self) -> OperatorMemoryContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.