Struct DistributedWorker 

pub struct DistributedWorker { /* private fields */ }

Worker node for distributed computation

Implementations

impl DistributedWorker

pub fn new(id: usize, config: DistributedConfig) -> Self

Create a new distributed worker

pub fn cache_result(&self, key: String, values: Vec<Float>) -> Result<()>

Store a named result in the worker’s result cache.

pub fn get_cached_result(&self, key: &str) -> Result<Option<Vec<Float>>>

Retrieve a cached result by key. Returns None when the key is absent.

pub fn all_cached_results(&self) -> Result<HashMap<String, Vec<Float>>>

Return a snapshot of all cached results for this worker.

pub fn assign_partition(&mut self, partition: DataPartition) -> Result<()>

Assign data partition to this worker

pub fn compute_local_pca(&self, n_components: usize) -> Result<LocalPCAResult>

Compute local PCA for assigned partitions

pub fn compute_local_svd(&self, n_components: usize) -> Result<LocalSVDResult>

Compute local SVD for assigned partitions