[][src]Module amadeus_core::dist_sink

Structs

All
AllReduceFactory
AllReducer
Any
AnyReduceFactory
AnyReducer
AsyncTuple0
AsyncTuple1
AsyncTuple2
AsyncTuple3
AsyncTuple4
AsyncTuple5
AsyncTuple6
AsyncTuple7
AsyncTuple8
BoolAndReduceFactory
BoolAndReducer
BoolOrReduceFactory
BoolOrReducer
Collect
Combine
CombineFn
CombineReduceFactory
CombineReducer
Count
CountReduceFactory
CountReducer
DefaultReduceFactory
ExtendReducer
Fold
FoldReducerA
FoldReducerAFactory
FoldReducerB
FoldReducerBFactory
ForEach
ForEachReduceFactory
ForEachReducer
IntoReducer
Max
MaxBy
MaxByKey
Min
MinBy
MinByKey
MostDistinct
MostDistinctReduceFactory
MostDistinctReducer
MostFrequent
MostFrequentReduceFactory
MostFrequentReducer
NonzeroReduceFactory
NonzeroReducer
OptionReduceFactory
OptionReducer
Peekable
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
ResultReduceFactory
ResultReducer
SampleUnstable
SampleUnstableReduceFactory
SampleUnstableReducer
Sum
SumReduceFactory
SumReducer

Enums

ResultReducerAsync

Traits

Combiner
DistributedSink
Factory
FromDistributedStream
Push
Reducer
ReducerAsync
ReducerProcessSend
ReducerSend