Struct PartitionHandle 

pub struct PartitionHandle {
    pub receivers: Vec<Receiver<PartitionMessage>>,
    pub error_rx: Mutex<Receiver<(usize, QueryError)>>,
    pub stop: Arc<AtomicBool>,
    pub partition_count: usize,
    pub buffered_chunks: Arc<AtomicUsize>,
    pub buffered_bytes: Arc<AtomicUsize>,
    pub buffered_chunks_peak: Arc<AtomicUsize>,
    pub buffered_bytes_peak: Arc<AtomicUsize>,
    pub worker_time_us: Arc<AtomicU64>,
    pub started_at: Instant,
    pub profile_recorded: bool,
    pub runtime: Arc<ExecutionRuntime>,
    /* private fields */
}

Handle for consuming results from a submitted batch.

Returned by MorselWorkerPool::submit(). Provides per-partition chunk access via next_for_partition().

Fields

receivers: Vec<Receiver<PartitionMessage>>

error_rx: Mutex<Receiver<(usize, QueryError)>>

stop: Arc<AtomicBool>

partition_count: usize

buffered_chunks: Arc<AtomicUsize>

buffered_bytes: Arc<AtomicUsize>

buffered_chunks_peak: Arc<AtomicUsize>

buffered_bytes_peak: Arc<AtomicUsize>

worker_time_us: Arc<AtomicU64>

started_at: Instant

profile_recorded: bool

runtime: Arc<ExecutionRuntime>

Implementations

impl PartitionHandle

pub fn next_for_partition_blocking( &mut self, partition_id: usize, ) -> Result<Option<DataChunk>, QueryError>

Pull one chunk from an individual partition, blocking until data is available instead of polling at the channel wait interval.

This is the drain fast path for the [GatherOperator::Concatenate] gather, which reads exactly one partition at a time: a blocking receive wakes the instant the producer sends a chunk, removing the up-to-CHANNEL_WAIT poll latency from the steady-state drain and avoiding producer/consumer wakeup gaps. Cancellation and worker errors are still observed at each chunk boundary because producers exit promptly on stop/cancel, which disconnects their sender.

pub fn next_for_partition( &mut self, partition_id: usize, ) -> Result<Option<DataChunk>, QueryError>

Pull one chunk from an individual partition.

pub fn stop_and_join(&mut self) -> Result<(), QueryError>

Trait Implementations

impl Debug for PartitionHandle

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

Formats the value using the given formatter.