[][src]Module amadeus::par_sink

Macros

combiner_dist_sink
combiner_par_sink
folder_dist_sink
folder_par_sink

Structs

All
AllReducer
AllReducerFactory
Any
AnyReducer
AnyReducerFactory
AsyncTuple0
AsyncTuple1
AsyncTuple2
AsyncTuple3
AsyncTuple4
AsyncTuple5
AsyncTuple6
AsyncTuple7
AsyncTuple8
BoolAndReducer
BoolAndReducerFactory
BoolOrReducer
BoolOrReducerFactory
Collect
Combine
Count
CountFolder
DefaultReducerFactory
ExtendReducer
Fold
FoldFolder
FolderSyncReducer
FolderSyncReducerAsync
FolderSyncReducerFactory
ForEach
ForEachReducer
ForEachReducerFactory
GroupBy
GroupByFolder
Histogram
HistogramFolder
IntoReducer
JoinTask
Max
MaxBy
MaxByKey
Min
MinBy
MinByKey
MostDistinct
MostDistinctFolder
MostFrequent
MostFrequentFolder
OptionReducer
OptionReducerFactory
Peekable
Pipe
PushReducer
ReduceA0
ReduceA0Async
ReduceA0Factory
ReduceA1Factory
ReduceA1
ReduceA1Async
ReduceA2Factory
ReduceA2
ReduceA2Async
ReduceA3Factory
ReduceA3
ReduceA3Async
ReduceA4Factory
ReduceA4
ReduceA4Async
ReduceA5Factory
ReduceA5
ReduceA5Async
ReduceA6Factory
ReduceA6
ReduceA6Async
ReduceA7Factory
ReduceA7
ReduceA7Async
ReduceA8Factory
ReduceA8
ReduceA8Async
ReduceC0
ReduceC0Async
ReduceC0Factory
ReduceC1Factory
ReduceC1
ReduceC1Async
ReduceC2Factory
ReduceC2
ReduceC2Async
ReduceC3Factory
ReduceC3
ReduceC3Async
ReduceC4Factory
ReduceC4
ReduceC4Async
ReduceC5Factory
ReduceC5
ReduceC5Async
ReduceC6Factory
ReduceC6
ReduceC6Async
ReduceC7Factory
ReduceC7
ReduceC7Async
ReduceC8Factory
ReduceC8
ReduceC8Async
ReduceFn
ResultReducer
ResultReducerFactory
SampleUnstable
SampleUnstableFolder
Sum
SumFolder
SumZeroFolder

Enums

ResultReducerAsync

Traits

CombinerSync
DistributedSink
Factory
FolderSync
FromDistributedStream
FromParallelStream
ParallelSink
Reducer
ReducerAsync
ReducerProcessSend
ReducerSend