Struct MockDistributedArray

pub struct MockDistributedArray<T: Clone + 'static> { /* private fields */ }

A mock distributed array implementation.

Implementations

impl<T: Clone + Send + Sync + 'static> MockDistributedArray<T>

pub fn new(chunks: Vec<T>, shape: Vec<usize>) -> Self

Create a new mock distributed array.

Trait Implementations

impl<T: Clone + Send + Sync + 'static> ArrayProtocol for MockDistributedArray<T>

fn array_function( &self, func: &ArrayFunction, _types: &[TypeId], _args: &[Box<dyn Any>], _kwargs: &HashMap<String, Box<dyn Any>>, ) -> Result<Box<dyn Any>, NotImplemented>

Implementation of the array protocol.

fn as_any(&self) -> &dyn Any

Get the array as Any for downcasting

fn shape(&self) -> &[usize]

Get the shape of the array (default implementation returns empty slice)

fn box_clone(&self) -> Box<dyn ArrayProtocol>

Clone this array protocol object.

fn dtype(&self) -> TypeId

Get the data type of the array (default implementation returns f64)

impl<T: Clone + Clone + 'static> Clone for MockDistributedArray<T>

fn clone(&self) -> MockDistributedArray<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Clone + 'static> Debug for MockDistributedArray<T>

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

Formats the value using the given formatter.

impl<T: Clone + Send + Sync + 'static> DistributedArray for MockDistributedArray<T>

fn distribution_info(&self) -> HashMap<String, String>

Get information about the distribution of this array.

fn gather(&self) -> CoreResult<Box<dyn ArrayProtocol>>

Gather the distributed array to a single node.

fn scatter(&self, _chunks: usize) -> CoreResult<Box<dyn DistributedArray>>

Scatter a regular array to a distributed array.

fn is_distributed(&self) -> bool

Check if this array is distributed.