Trait amadeus_core::par_sink::FolderSync

pub trait FolderSync<Item> {
    type Done;
    fn zero(&mut self) -> Self::Done;
    fn push(&mut self, state: &mut Self::Done, item: Item);
}

Associated Types

type Done

Loading content...

Required methods

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

Loading content...

Implementors

impl<A, B> FolderSync<(A, B)> for MostDistinctFolder where
    A: Clone + Hash + Eq + Send + 'static,
    B: Hash + 'static, 

type Done = Top<A, HyperLogLogMagnitude<B>>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: (A, B))

impl<A, ID, F, Item> FolderSync<Item> for FoldFolder<A, ID, F, Item, StepB> where
    ID: FnMut<(), Output = Item>,
    F: FnMut<(Item, Either<A, Item>), Output = Item>, 

type Done = Item

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<B> FolderSync<Vec<(B, usize)>> for HistogramFolder<B, StepB> where
    B: Hash + Ord, 

type Done = Vec<(B, usize)>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, b: Vec<(B, usize)>)

impl<B> FolderSync<HashMap<B, usize, RandomState>> for HistogramFolder<B, StepB> where
    B: Hash + Ord, 

type Done = Vec<(B, usize)>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, b: HashMap<B, usize>)

impl<C, Item, B> FolderSync<Item> for C where
    C: CombinerSync<Done = B>,
    Item: Into<Option<B>>, 

type Done = Option<B>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<F, A, Item> FolderSync<Item> for ReduceFn<F, A> where
    F: FnMut<(A, A), Output = A>,
    Item: Into<Option<A>>, 

type Done = Option<A>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item> FolderSync<Item> for CountFolder

type Done = usize

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, _item: Item)

impl<Item> FolderSync<Item> for HistogramFolder<Item, StepA> where
    Item: Hash + Ord, 

type Done = HashMap<Item, usize>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item> FolderSync<Item> for MostFrequentFolder where
    Item: Clone + Hash + Eq + Send + 'static, 

type Done = Top<Item, usize>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item> FolderSync<Item> for SampleUnstableFolder

type Done = SASampleUnstable<Item>

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item> FolderSync<Item> for SumZeroFolder<Item> where
    Option<Item>: Sum<Item>, 

type Done = Item

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item, B> FolderSync<Item> for SumFolder<B> where
    B: Sum<Item> + Sum<B>, 

type Done = B

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

impl<Item, ID, F, B> FolderSync<Item> for FoldFolder<Item, ID, F, B, StepA> where
    ID: FnMut<(), Output = B>,
    F: FnMut<(B, Either<Item, B>), Output = B>, 

type Done = B

fn zero(&mut self) -> Self::Done

fn push(&mut self, state: &mut Self::Done, item: Item)

Loading content...