Enum RowSet 

pub enum RowSet {
    All,
    Subsample {
        rows: Arc<Vec<WeightedOuterRow>>,
        n_full: usize,
    },
}

Row selection for an outer-loop evaluation: either the full data (All) or a Horvitz–Thompson WeightedOuterRow subsample.

All walks rows 0..n_total with unit weight; Subsample walks the stored rows applying each row’s inverse-inclusion scale 1/π_i, so any partial sum Σ_i w_i · f(row_i) is an unbiased estimator of the corresponding full-data sum Σ_{i=1..n_full} f(row_i). Inner-PIRLS and final-covariance passes always run with All; only outer score / gradient hot loops consume a non-All variant.

Lives in this lower layer (below families/terms) so the row-kernel consumers and the term hot-paths can name it without the Subsample field reaching up into solver (#1135). The family-specific constructor (families::row_kernel::RowSet::from_options, which reads custom_family::BlockwiseFitOptions) stays in families as an extension impl block.

Variants

All

Subsample

Fields

rows: Arc<Vec<WeightedOuterRow>>

n_full: usize

Implementations

impl RowSet

pub fn par_reduce_fold<T, I, F, R>( &self, n_total: usize, init: I, fold: F, reduce: R, ) -> T

where T: Send, I: Fn() -> T + Send + Sync, F: Fn(T, usize, f64) -> T + Send + Sync, R: Fn(T, T) -> T + Send + Sync,

Parallel fold-reduce over the row set. init produces a fresh accumulator, fold is the per-row update, reduce combines two accumulators.

Returns the reduced result. Both branches process fixed-size row chunks in parallel, then combine the chunk accumulators in chunk-index order on the caller thread. The resulting floating-point reduction tree is fixed across Rayon worker counts and work-stealing decisions.

pub fn par_try_reduce_fold<T, E, I, F, R>( &self, n_total: usize, init: I, fold: F, reduce: R, ) -> Result<T, E>

where T: Send, E: Send, I: Fn() -> T + Send + Sync, F: Fn(T, usize, f64) -> Result<T, E> + Send + Sync, R: Fn(T, T) -> Result<T, E> + Send + Sync,

Parallel try-fold over fixed-size row chunks, followed by deterministic chunk-index-order reduction on the caller thread.

Trait Implementations

impl Clone for RowSet

fn clone(&self) -> RowSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.