Struct SharedPoolMorselScheduler 

pub struct SharedPoolMorselScheduler { /* private fields */ }

Implementations

impl SharedPoolMorselScheduler

pub fn new(pool: SharedExecutorPool) -> Self

pub fn execute<T, F>( &self, admission: &MorselAdmission, execute: F, ) -> Result<Vec<T>>

where T: Send, F: Fn(Morsel) -> Result<T> + Sync,

pub fn execute_with_context<T, F>( &self, admission: &MorselAdmission, context: &RuntimeTaskContext, execute: F, ) -> Result<Vec<T>>

where T: Send, F: Fn(Morsel) -> Result<T> + Sync,

pub fn execute_accounted_ordered<T, F, C>( &self, admission: &MorselAdmission, resources: MorselStreamResources<'_>, execute: F, consume: C, ) -> Result<MorselStreamReport>

where T: Send, F: Fn(Morsel) -> Result<MorselOutput<T>> + Sync, C: FnMut(Morsel, T) -> Result<MorselStreamControl>,

Streams worker outputs through a bounded channel and invokes the coordinator consumer in stable morsel ordinal order.

output_reservation_bytes is charged before the worker calls execute. The returned resident estimate must fit that reservation. The lease remains live through consume, so a consumer that retains the value must transfer it into another query-owned account.

Trait Implementations

impl Clone for SharedPoolMorselScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedPoolMorselScheduler

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

Formats the value using the given formatter.