Struct BorderGramCheckpoint 

pub struct BorderGramCheckpoint {
    pub border_dim: usize,
    pub n_rows: usize,
    pub chunk_size: usize,
    pub frontier: usize,
    pub block_partial: Option<Vec<f64>>,
    pub block_len: usize,
    pub forest: Vec<(usize, Vec<f64>)>,
    pub pending: Vec<(usize, Vec<f64>)>,
}

Serializable accumulation state of a StreamingBorderGram: the partial Grams plus the chunk cursor. Writing this to disk after every accepted chunk makes a preempted multi-hour pass resumable instead of restartable; StreamingBorderGram::resume reconstructs the accumulator with bit-identical future behavior (resume-equals-straight-through).

Fields

border_dim: usize

Border dimension k (columns of every submitted chunk).

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).

frontier: usize

Chunk cursor: number of chunks already folded into the in-order cascade. Chunk indices < frontier are consumed; the next in-order fold is chunk frontier.

block_partial: Option<Vec<f64>>

Sequential partial of the current (unsealed) cross-chunk base block, flattened k·k row-major. None iff block_len == 0.

block_len: usize

Number of chunk partials folded into block_partial (0..CROSS_CHUNK_BASE).

forest: Vec<(usize, Vec<f64>)>

Completed cascade subtrees: (weight in chunks, flattened k·k partial) with strictly decreasing power-of-two-multiple-of-base weights, bottom to top — exactly the StreamingPairwise forest invariant.

pending: Vec<(usize, Vec<f64>)>

Out-of-order chunk partials waiting for the frontier to reach them: (chunk_index, flattened k·k chunk Gram), all indices > frontier.

Trait Implementations

impl Clone for BorderGramCheckpoint

fn clone(&self) -> BorderGramCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BorderGramCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BorderGramCheckpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for BorderGramCheckpoint

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

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 BorderGramCheckpoint