Struct ShardSnapshot 

pub struct ShardSnapshot {
    pub shard_id: usize,
    pub entities: Vec<Vec<f32>>,
    pub entity_ids: Vec<String>,
    pub relations: Vec<Vec<f32>>,
    pub relation_ids: Vec<String>,
    pub step: u64,
}

Public-facing snapshot of one shard’s contents.

Returned by ParameterServer::pull. Workers operate on this owned copy locally, then submit gradients via push.

Fields

shard_id: usize

Shard index.

entities: Vec<Vec<f32>>

One row of embedding_dim weights per entity owned by the shard.

entity_ids: Vec<String>

Mapping from row index inside entities back to the global entity ID.

relations: Vec<Vec<f32>>

Relation table — small, replicated to every shard for convenience.

relation_ids: Vec<String>

Mapping from row index inside relations back to the global relation ID.

step: u64

Server step counter at the moment the snapshot was taken.

Trait Implementations

impl Clone for ShardSnapshot

fn clone(&self) -> ShardSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShardSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ShardSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ShardSnapshot

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

where __S: Serializer,

Serialize this value into the given Serde serializer.