Trait kgdata::mapreduce::FromParallelDataset

pub trait FromParallelDataset<I> {
    // Required method
    fn from_par_dataset<D>(dataset: D) -> Self
       where D: ParallelDataset<Item = I>;
}

Required Methods

fn from_par_dataset<D>(dataset: D) -> Self

where D: ParallelDataset<Item = I>,

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<I> FromParallelDataset<I> for Vec<I>

where I: Send,

fn from_par_dataset<D>(dataset: D) -> Self

where D: ParallelDataset<Item = I>,

impl<I, E> FromParallelDataset<Result<I, E>> for Result<Dataset<I>, E>

where I: Send, E: Send,

fn from_par_dataset<D>(iter: D) -> Self

where D: IntoParallelIterator<Item = Result<I, E>>,

impl<I, E> FromParallelDataset<Result<I, E>> for Result<Vec<I>, E>

where I: Send, E: Send,

fn from_par_dataset<D>(dataset: D) -> Self

where D: ParallelDataset<Item = Result<I, E>>,

impl<K, V> FromParallelDataset<(K, V)> for HashMap<K, V>

where K: Hash + Eq + Send, V: Send,

fn from_par_dataset<D>(dataset: D) -> Self

where D: ParallelDataset<Item = (K, V)>,

impl<K, V, E> FromParallelDataset<Result<(K, V), E>> for Result<HashMap<K, V>, E>

where K: Hash + Eq + Send, V: Send, E: Send,

fn from_par_dataset<D>(dataset: D) -> Self

where D: ParallelDataset<Item = Result<(K, V), E>>,

Implementors

impl<I> FromParallelDataset<I> for Dataset<I>

where I: Send,