Module amadeus::par_sink

Structs

All
AllReducer
AllReducerAsync
Any
AnyReducer
AnyReducerAsync
AsyncTuple0
AsyncTuple1
AsyncTuple2
AsyncTuple3
AsyncTuple4
AsyncTuple5
AsyncTuple6
AsyncTuple7
AsyncTuple8
BoolAndReducer
BoolAndReducerAsync
BoolOrReducer
BoolOrReducerAsync
Collect
Combine
Count
CountFolder
ExtendReducer
ExtendReducerAsync
Final
Fold
FoldFolder
FolderSyncReducer
FolderSyncReducerAsync
ForEach
ForEachReducer
Fork
GroupBy
GroupByReducerA
GroupByReducerAAsync
GroupByReducerB
GroupByReducerBAsync
Histogram
HistogramFolder
Inter
IntoReducer
IntoReducerAsync
JoinStreamTaskAsync
Max
MaxBy
MaxByKey
Mean
MeanFolder
Min
MinBy
MinByKey
MostDistinct
MostDistinctFolder
MostFrequent
MostFrequentFolder
OptionReducer
OptionReducerAsync
Peekable
Pipe
PushReducer
PushReducerAsync
ReduceA0
ReduceA0Async
ReduceA1
ReduceA1Async
ReduceA2
ReduceA2Async
ReduceA3
ReduceA3Async
ReduceA4
ReduceA4Async
ReduceA5
ReduceA5Async
ReduceA6
ReduceA6Async
ReduceA7
ReduceA7Async
ReduceA8
ReduceA8Async
ReduceC0
ReduceC0Async
ReduceC1
ReduceC1Async
ReduceC2
ReduceC2Async
ReduceC3
ReduceC3Async
ReduceC4
ReduceC4Async
ReduceC5
ReduceC5Async
ReduceC6
ReduceC6Async
ReduceC7
ReduceC7Async
ReduceC8
ReduceC8Async
ReduceFn
ResultReducer
SDFolder
SDState
SampleUnstable
SampleUnstableFolder
Sort
SortFolder
State
StdDev
Sum
SumFolder
SumZeroFolder

Enums

ResultReducerAsync

Traits

CombinerSync
DistributedSink
FolderSync
FromDistributedStream
FromParallelStream
ParallelSink
Reducer
ReducerProcessSend
ReducerSend