| 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.