Struct CrossNodePartition 

pub struct CrossNodePartition {
    pub border_dim: usize,
    pub n_rows: usize,
    pub chunk_size: usize,
    pub n_ranks: usize,
}

The deterministic chunk partition + rank-indexed assignment shared by every participant of one cross-node pass. A pure function of its four fields; two participants constructed with the same fields agree on every derived quantity, with no communication.

Fields

border_dim: usize

Border dimension k (columns of every chunk; partials are k·k).

n_rows: usize

Total row count of the full pass.

chunk_size: usize

Fixed chunk size (rows per chunk; the last chunk may be shorter).

n_ranks: usize

Number of worker ranks in the fleet.

Implementations

impl CrossNodePartition

pub fn new( border_dim: usize, n_rows: usize, chunk_size: usize, n_ranks: usize, ) -> Result<Self, String>

pub fn n_chunks(&self) -> usize

Total number of chunks of the pass: ceil(n_rows / chunk_size). Identical to StreamingBorderGram::n_chunks for the same partition parameters — the global tree this assignment feeds.

pub fn chunk_rows(&self, chunk_index: usize) -> Range<usize>

Row range covered by global chunk chunk_index — the same pure function as StreamingBorderGram::chunk_rows, duplicated here so a worker can slice its rows without constructing a coordinator-side accumulator.

pub fn owner_rank(&self, chunk_index: usize) -> usize

Which rank owns global chunk chunk_index: round-robin by index.

pub fn chunks_owned_by(&self, rank: usize) -> usize

Number of chunks rank rank owns.

pub fn owned_chunk(&self, rank: usize, ordinal: usize) -> Option<usize>

The ordinal-th (0-based) global chunk index owned by rank, or None past the end of the rank’s sequence. The worker cursor is an ordinal into exactly this sequence.

Trait Implementations

impl Clone for CrossNodePartition

fn clone(&self) -> CrossNodePartition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for CrossNodePartition

impl Debug for CrossNodePartition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CrossNodePartition

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CrossNodePartition

impl PartialEq for CrossNodePartition

fn eq(&self, other: &CrossNodePartition) -> 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 Serialize for CrossNodePartition

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CrossNodePartition