[−][src]Trait amadeus_core::par_sink::DistributedSink
Associated Types
type Output
type Pipe: DistributedPipe<Source>
type ReduceA: ReducerSend<<Self::Pipe as DistributedPipe<Source>>::Item> + Clone + ProcessSend + Send
type ReduceB: ReducerProcessSend<<Self::ReduceA as ReducerSend<<Self::Pipe as DistributedPipe<Source>>::Item>>::Output> + Clone + ProcessSend
type ReduceC: Reducer<<Self::ReduceB as ReducerProcessSend<<Self::ReduceA as ReducerSend<<Self::Pipe as DistributedPipe<Source>>::Item>>::Output>>::Output, Output = Self::Output>
Required methods
Loading content...Implementations on Foreign Types
impl<Source> DistributedSink<Source> for () where
Source: ,
[src]
Source: ,
type Output = ()
type Pipe = ()
type ReduceA = ReduceA0
type ReduceB = ReduceC0
type ReduceC = ReduceC0
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, O0> DistributedSink<Source> for (R0,) where
Source: ,
[src]
Source: ,
type Output = (O0,)
type Pipe = (R0::Pipe,)
type ReduceA = ReduceA1<R0::ReduceA>
type ReduceB = ReduceC1<R0::ReduceB>
type ReduceC = ReduceC1<R0::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, O0, O1> DistributedSink<Source> for (R0, R1) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1)
type Pipe = (R0::Pipe, R1::Pipe)
type ReduceA = ReduceA2<R0::ReduceA, R1::ReduceA>
type ReduceB = ReduceC2<R0::ReduceB, R1::ReduceB>
type ReduceC = ReduceC2<R0::ReduceC, R1::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, O0, O1, O2> DistributedSink<Source> for (R0, R1, R2) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe)
type ReduceA = ReduceA3<R0::ReduceA, R1::ReduceA, R2::ReduceA>
type ReduceB = ReduceC3<R0::ReduceB, R1::ReduceB, R2::ReduceB>
type ReduceC = ReduceC3<R0::ReduceC, R1::ReduceC, R2::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, R3: DistributedSink<Source, Output = O3>, O0, O1, O2, O3> DistributedSink<Source> for (R0, R1, R2, R3) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2, O3)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe, R3::Pipe)
type ReduceA = ReduceA4<R0::ReduceA, R1::ReduceA, R2::ReduceA, R3::ReduceA>
type ReduceB = ReduceC4<R0::ReduceB, R1::ReduceB, R2::ReduceB, R3::ReduceB>
type ReduceC = ReduceC4<R0::ReduceC, R1::ReduceC, R2::ReduceC, R3::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, R3: DistributedSink<Source, Output = O3>, R4: DistributedSink<Source, Output = O4>, O0, O1, O2, O3, O4> DistributedSink<Source> for (R0, R1, R2, R3, R4) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2, O3, O4)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe, R3::Pipe, R4::Pipe)
type ReduceA = ReduceA5<R0::ReduceA, R1::ReduceA, R2::ReduceA, R3::ReduceA, R4::ReduceA>
type ReduceB = ReduceC5<R0::ReduceB, R1::ReduceB, R2::ReduceB, R3::ReduceB, R4::ReduceB>
type ReduceC = ReduceC5<R0::ReduceC, R1::ReduceC, R2::ReduceC, R3::ReduceC, R4::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, R3: DistributedSink<Source, Output = O3>, R4: DistributedSink<Source, Output = O4>, R5: DistributedSink<Source, Output = O5>, O0, O1, O2, O3, O4, O5> DistributedSink<Source> for (R0, R1, R2, R3, R4, R5) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2, O3, O4, O5)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe, R3::Pipe, R4::Pipe, R5::Pipe)
type ReduceA = ReduceA6<R0::ReduceA, R1::ReduceA, R2::ReduceA, R3::ReduceA, R4::ReduceA, R5::ReduceA>
type ReduceB = ReduceC6<R0::ReduceB, R1::ReduceB, R2::ReduceB, R3::ReduceB, R4::ReduceB, R5::ReduceB>
type ReduceC = ReduceC6<R0::ReduceC, R1::ReduceC, R2::ReduceC, R3::ReduceC, R4::ReduceC, R5::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, R3: DistributedSink<Source, Output = O3>, R4: DistributedSink<Source, Output = O4>, R5: DistributedSink<Source, Output = O5>, R6: DistributedSink<Source, Output = O6>, O0, O1, O2, O3, O4, O5, O6> DistributedSink<Source> for (R0, R1, R2, R3, R4, R5, R6) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2, O3, O4, O5, O6)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe, R3::Pipe, R4::Pipe, R5::Pipe, R6::Pipe)
type ReduceA = ReduceA7<R0::ReduceA, R1::ReduceA, R2::ReduceA, R3::ReduceA, R4::ReduceA, R5::ReduceA, R6::ReduceA>
type ReduceB = ReduceC7<R0::ReduceB, R1::ReduceB, R2::ReduceB, R3::ReduceB, R4::ReduceB, R5::ReduceB, R6::ReduceB>
type ReduceC = ReduceC7<R0::ReduceC, R1::ReduceC, R2::ReduceC, R3::ReduceC, R4::ReduceC, R5::ReduceC, R6::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<Source, R0: DistributedSink<Source, Output = O0>, R1: DistributedSink<Source, Output = O1>, R2: DistributedSink<Source, Output = O2>, R3: DistributedSink<Source, Output = O3>, R4: DistributedSink<Source, Output = O4>, R5: DistributedSink<Source, Output = O5>, R6: DistributedSink<Source, Output = O6>, R7: DistributedSink<Source, Output = O7>, O0, O1, O2, O3, O4, O5, O6, O7> DistributedSink<Source> for (R0, R1, R2, R3, R4, R5, R6, R7) where
Source: Copy,
[src]
Source: Copy,
type Output = (O0, O1, O2, O3, O4, O5, O6, O7)
type Pipe = (R0::Pipe, R1::Pipe, R2::Pipe, R3::Pipe, R4::Pipe, R5::Pipe, R6::Pipe, R7::Pipe)
type ReduceA = ReduceA8<R0::ReduceA, R1::ReduceA, R2::ReduceA, R3::ReduceA, R4::ReduceA, R5::ReduceA, R6::ReduceA, R7::ReduceA>
type ReduceB = ReduceC8<R0::ReduceB, R1::ReduceB, R2::ReduceB, R3::ReduceB, R4::ReduceB, R5::ReduceB, R6::ReduceB, R7::ReduceB>
type ReduceC = ReduceC8<R0::ReduceC, R1::ReduceC, R2::ReduceC, R3::ReduceC, R4::ReduceC, R5::ReduceC, R6::ReduceC, R7::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
Implementors
impl<A, B, C, Source, RefAItem> DistributedSink<Source> for Fork<A, B, C, RefAItem> where
A: DistributedPipe<Source>,
B: DistributedSink<A::Item>,
C: DistributedSink<RefAItem>,
RefAItem: 'static,
[src]
A: DistributedPipe<Source>,
B: DistributedSink<A::Item>,
C: DistributedSink<RefAItem>,
RefAItem: 'static,
type Output = (B::Output, C::Output)
type Pipe = Fork<A, B::Pipe, C::Pipe, RefAItem>
type ReduceA = ReduceA2<B::ReduceA, C::ReduceA>
type ReduceB = ReduceC2<B::ReduceB, C::ReduceB>
type ReduceC = ReduceC2<B::ReduceC, C::ReduceC>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<A: DistributedPipe<Source>, B: DistributedSink<A::Item>, Source> DistributedSink<Source> for Pipe<A, B>
[src]
type Output = B::Output
type Pipe = Pipe<A, B::Pipe>
type ReduceA = B::ReduceA
type ReduceB = B::ReduceB
type ReduceC = B::ReduceC
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<A: DistributedPipe<Source, Item = (T, U)>, B: DistributedSink<U>, Source, T, U> DistributedSink<Source> for GroupBy<A, B> where
T: Eq + Hash + ProcessSend + 'static,
<B::Pipe as DistributedPipe<U>>::Task: Clone + ProcessSend + 'static,
B::ReduceA: Clone + ProcessSend + 'static,
B::ReduceB: Clone,
B::ReduceC: Clone,
B::Output: ProcessSend + 'static,
[src]
T: Eq + Hash + ProcessSend + 'static,
<B::Pipe as DistributedPipe<U>>::Task: Clone + ProcessSend + 'static,
B::ReduceA: Clone + ProcessSend + 'static,
B::ReduceB: Clone,
B::ReduceC: Clone,
B::Output: ProcessSend + 'static,
type Output = HashMap<T, B::Output>
type Pipe = A
type ReduceA = GroupByReducerA<<B::Pipe as DistributedPipe<U>>::Task, B::ReduceA, T, U>
type ReduceB = GroupByReducerB<B::ReduceB, T, <B::ReduceA as ReducerSend<<B::Pipe as DistributedPipe<U>>::Item>>::Output>
type ReduceC = GroupByReducerB<B::ReduceC, T, <B::ReduceB as ReducerProcessSend<<B::ReduceA as Reducer<<B::Pipe as DistributedPipe<U>>::Item>>::Output>>::Output>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: DistributedPipe<Source>, Source, F> DistributedSink<Source> for All<I, F> where
F: FnMut<(I::Item,), Output = bool> + Clone + ProcessSend + 'static,
[src]
F: FnMut<(I::Item,), Output = bool> + Clone + ProcessSend + 'static,
type Output = bool
type Pipe = I
type ReduceA = AllReducer<I::Item, F>
type ReduceB = BoolAndReducer
type ReduceC = BoolAndReducer
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: DistributedPipe<Source>, Source, F> DistributedSink<Source> for Any<I, F> where
F: FnMut<(I::Item,), Output = bool> + Clone + ProcessSend + 'static,
[src]
F: FnMut<(I::Item,), Output = bool> + Clone + ProcessSend + 'static,
type Output = bool
type Pipe = I
type ReduceA = AnyReducer<I::Item, F>
type ReduceB = BoolOrReducer
type ReduceC = BoolOrReducer
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: DistributedPipe<Source>, Source, F> DistributedSink<Source> for ForEach<I, F> where
F: FnMut<(I::Item,), Output = ()> + Clone + ProcessSend + 'static,
[src]
F: FnMut<(I::Item,), Output = ()> + Clone + ProcessSend + 'static,
type Output = ()
type Pipe = I
type ReduceA = ForEachReducer<I::Item, F>
type ReduceB = PushReducer<()>
type ReduceC = PushReducer<()>
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: DistributedPipe<Source>, Source, T: FromDistributedStream<I::Item>> DistributedSink<Source> for Collect<I, T>
[src]
type Output = T
type Pipe = I
type ReduceA = T::ReduceA
type ReduceB = T::ReduceB
type ReduceC = T::ReduceC
fn reducers(self) -> (Self::Pipe, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for Count<I>
[src]
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, CountFolder>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, SumFolder<usize>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, SumFolder<usize>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for Histogram<I> where
I::Item: Hash + Ord + Send + 'static,
[src]
I::Item: Hash + Ord + Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, HistogramFolder<I::Item, StepA>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, HistogramFolder<I::Item, StepB>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, HistogramFolder<I::Item, StepB>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for Max<I> where
I::Item: Ord + Send + 'static,
[src]
I::Item: Ord + Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, Max<I::Item>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, Max<I::Item>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, Max<I::Item>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for Min<I> where
I::Item: Ord + Send + 'static,
[src]
I::Item: Ord + Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, Min<I::Item>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, Min<I::Item>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, Min<I::Item>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for MostFrequent<I> where
I::Item: Clone + Hash + Eq + Send + 'static,
[src]
I::Item: Clone + Hash + Eq + Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, MostFrequentFolder>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, SumZeroFolder<Top<I::Item, usize>>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, SumZeroFolder<Top<I::Item, usize>>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source> DistributedSink<Source> for SampleUnstable<I> where
I::Item: Send + 'static,
[src]
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, SampleUnstableFolder>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, SumFolder<SASampleUnstable<I::Item>>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, SumFolder<SASampleUnstable<I::Item>>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, B> DistributedSink<Source> for Sum<I, B> where
B: Sum<I::Item> + Sum<B> + Send + 'static,
[src]
B: Sum<I::Item> + Sum<B> + Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, SumFolder<B>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, SumFolder<B>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, SumFolder<B>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, F> DistributedSink<Source> for Combine<I, F> where
F: FnMut<(I::Item, I::Item), Output = I::Item> + Clone + Send + 'static,
I::Item: Send + 'static,
[src]
F: FnMut<(I::Item, I::Item), Output = I::Item> + Clone + Send + 'static,
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, ReduceFn<F, I::Item>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, ReduceFn<F, I::Item>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, ReduceFn<F, I::Item>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, F> DistributedSink<Source> for MaxBy<I, F> where
F: for<'a, 'b> FnMut<(&'a I::Item, &'b I::Item), Output = Ordering> + Clone + Send + 'static,
I::Item: Send + 'static,
[src]
F: for<'a, 'b> FnMut<(&'a I::Item, &'b I::Item), Output = Ordering> + Clone + Send + 'static,
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, MaxBy<I::Item, F>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, MaxBy<I::Item, F>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, MaxBy<I::Item, F>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, F> DistributedSink<Source> for MinBy<I, F> where
F: for<'a, 'b> FnMut<(&'a I::Item, &'b I::Item), Output = Ordering> + Clone + Send + 'static,
I::Item: Send + 'static,
[src]
F: for<'a, 'b> FnMut<(&'a I::Item, &'b I::Item), Output = Ordering> + Clone + Send + 'static,
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, MinBy<I::Item, F>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, MinBy<I::Item, F>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, MinBy<I::Item, F>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, F, B> DistributedSink<Source> for MaxByKey<I, F> where
F: for<'a> FnMut<(&'a I::Item,), Output = B> + Clone + Send + 'static,
B: Ord + 'static,
I::Item: Send + 'static,
[src]
F: for<'a> FnMut<(&'a I::Item,), Output = B> + Clone + Send + 'static,
B: Ord + 'static,
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, MaxByKey<I::Item, F, B>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, MaxByKey<I::Item, F, B>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, MaxByKey<I::Item, F, B>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, F, B> DistributedSink<Source> for MinByKey<I, F> where
F: for<'a> FnMut<(&'a I::Item,), Output = B> + Clone + Send + 'static,
B: Ord + 'static,
I::Item: Send + 'static,
[src]
F: for<'a> FnMut<(&'a I::Item,), Output = B> + Clone + Send + 'static,
B: Ord + 'static,
I::Item: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, MinByKey<I::Item, F, B>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, MinByKey<I::Item, F, B>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, MinByKey<I::Item, F, B>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source>, Source, ID, F, B> DistributedSink<Source> for Fold<I, ID, F, B> where
ID: FnMut<(), Output = B> + Clone + Send + 'static,
F: FnMut<(B, Either<I::Item, B>), Output = B> + Clone + Send + 'static,
B: Send + 'static,
[src]
ID: FnMut<(), Output = B> + Clone + Send + 'static,
F: FnMut<(B, Either<I::Item, B>), Output = B> + Clone + Send + 'static,
B: Send + 'static,
type Output = <Self::ReduceC as Reducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output>>::Output
type Pipe = I
type ReduceA = FolderSyncReducer<I::Item, FoldFolder<I::Item, ID, F, B, StepA>>
type ReduceB = FolderSyncReducer<<Self::ReduceA as Reducer<I::Item>>::Output, FoldFolder<I::Item, ID, F, B, StepB>>
type ReduceC = FolderSyncReducer<<Self::ReduceB as Reducer<<Self::ReduceA as Reducer<I::Item>>::Output>>::Output, FoldFolder<I::Item, ID, F, B, StepB>>
fn reducers(self) -> (I, Self::ReduceA, Self::ReduceB, Self::ReduceC)
[src]
impl<I: ParallelPipe<Source, Item = (A, B)>, Source, A, B> DistributedSink<Source> for MostDistinct<I> where
A: Clone + Hash + Eq + Send + 'static,
B: Hash + 'static,
[src]
A: Clone + Hash + Eq + Send + 'static,
B: Hash + 'static,