Struct NodeWorker 

pub struct NodeWorker { /* private fields */ }

Worker-side driver for one rank: walks the rank’s deterministic owned-chunk sequence, turning row slices into shippable NodePartials.

The worker does not do I/O: the caller streams rows (from its shards / object store) for the row range NodeWorker::next_chunk_rows names, hands them to NodeWorker::emit, and ships the returned partial. The cursor advances only on emit, so “ship durably, then checkpoint” gives exactly- once production under crash-resume (re-shipping an already-folded chunk is rejected by the coordinator as a duplicate, which is the safe failure).

Implementations

impl NodeWorker

pub fn new(partition: CrossNodePartition, rank: usize) -> Result<Self, String>

Fresh worker for rank, starting at the beginning of its sequence.

pub fn resume(state: NodeWorkerCheckpoint) -> Result<Self, String>

Resume a (replacement) worker from a serialized cursor. Validates the cursor against the partition so a checkpoint from a different pass is rejected loudly.

pub fn checkpoint(&self) -> NodeWorkerCheckpoint

Serialize the cursor. Write this (durably) after each successful ship.

pub fn is_done(&self) -> bool

true once this rank’s sequence is exhausted.

pub fn next_chunk_rows(&self) -> Option<(usize, Range<usize>)>

Global chunk index and row range of the next chunk to compute, or None when done. The caller fetches exactly these rows.

pub fn emit(&mut self, rows: ArrayView2<'_, f64>) -> Result<NodePartial, String>

Compute the next chunk’s deterministic partial from its rows and advance the cursor. rows must be exactly the rows of NodeWorker::next_chunk_rows (shape-validated here; content is the caller’s contract, same as the in-process path).

Trait Implementations

impl Clone for NodeWorker

fn clone(&self) -> NodeWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeWorker

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

Formats the value using the given formatter.