Class | Description |
---|---|
DefaultIfEmptyAction<T> | |
DematerializeAction<T> | |
GroupByAction<T,K> |
Manage a dynamic registry of substreams for a given key extracted from the incoming data.
|
MapAction<T,V> | |
MaterializeAction<T> | |
ScanAction<T,A> | |
SplitAction<T> |
Copyright © 2016. All rights reserved.