Struct Morsel 

pub struct Morsel {
    pub id: usize,
    pub source_id: usize,
    pub start_row: usize,
    pub end_row: usize,
}

A morsel represents a unit of work for parallel execution.

Each morsel identifies a range of rows from a source to be processed by a single worker thread.

Fields

id: usize

Unique identifier for this morsel within a pipeline execution.

source_id: usize

Source partition identifier (for multi-source queries).

start_row: usize

Starting row index (inclusive).

end_row: usize

Ending row index (exclusive).

Implementations

impl Morsel

pub fn new( id: usize, source_id: usize, start_row: usize, end_row: usize, ) -> Self

Creates a new morsel.

pub fn row_count(&self) -> usize

Returns the number of rows in this morsel.

pub fn is_empty(&self) -> bool

Returns whether this morsel is empty.

pub fn split_at(&self, offset: usize) -> Option<(Morsel, Morsel)>

Splits this morsel into two at the given row offset.

Returns None if the split point is outside the morsel range.

Trait Implementations

impl Clone for Morsel

fn clone(&self) -> Morsel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Morsel

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

Formats the value using the given formatter.

impl Hash for Morsel

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 Morsel

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for Morsel

impl Eq for Morsel

impl StructuralPartialEq for Morsel