Struct SamplerState 

pub struct SamplerState {

    pub version: u32,
    pub source_id: String,
    pub source_length: usize,
    pub rank: usize,
    pub world_size: usize,
    pub epoch: u64,
    pub shuffle_seed: Option<u64>,
    pub tail: SampleTail,
    pub epoch_size: usize,
    pub carried_consumed: usize,
    pub scope_size: usize,
    pub indices: Vec<usize>,
    pub committed: usize,
}

Available on crate feature std only.

Actual rank-local sample order and its committed cursor.

The order itself is recorded, so restoration does not depend on reconstructing a previous rand version’s permutation. Outstanding prefetch is NOT committed: restore begins at committed, replaying issued-but-unconsumed samples.

Fields

version: u32

Record format, currently one.

source_id: String

Caller-supplied identity of the immutable dataset/version.

source_length: usize

Original source length, not a rank-local length.

rank: usize

Data rank; tensor/pipeline ranks may use the same data coordinate.

world_size: usize

Data replicas assigning distinct examples.

epoch: u64

Current caller-selected epoch number.

shuffle_seed: Option<u64>

Private shuffle seed; None selects original source order.

tail: SampleTail

Tail policy used when starting a fresh epoch.

epoch_size: usize

Size of the originally selected epoch, after its initial tail policy.

carried_consumed: usize

Global consumption preceding the most recent topology change.

scope_size: usize

Remaining global scope assigned at that topology change.

indices: Vec<usize>

Actual local order; positions are original dataset indices.

committed: usize

Samples actually consumed by this rank from this scope.

Implementations

impl SamplerState

pub fn validate(&self) -> Result<(), SamplerError>

Validate rank geometry, ordering, bounds and committed accounting.

Trait Implementations

impl Clone for SamplerState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SamplerState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SamplerState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SamplerState

impl PartialEq for SamplerState

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

Equality operator ==.

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

Inequality operator !=.

impl<B: Backend> Record<B> for SamplerState

type Item<P: PrecisionSettings> = SamplerState

Type of the item that can be serialized and deserialized.

fn into_item<P: PrecisionSettings>(self) -> Self

Convert the current record into the corresponding item that follows the given settings.

fn from_item<P: PrecisionSettings>(item: Self, _: &B::Device) -> Self

Convert the given item into a record.

impl Serialize for SamplerState

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 SamplerState