| AggregatingState<IN,OUT> |
|
| AppendingState<IN,OUT,SYNCOUT> |
Base interface for partitioned state that supports adding elements and inspecting the current
state.
|
| ListState<T> |
State interface for partitioned list state in Operations. |
| MapState<UK,UV> |
State interface for partitioned key-value state. |
| MergingState<IN,OUT,SYNCOUT> |
|
| ReducingState<T> |
State interface for reducing state. |
| State |
Interface that different types of partitioned state must implement.
|
| StateFuture<T> |
StateFuture is a future that act as a return value for async state interfaces.
|
| StateIterator<T> |
Asynchronous iterators allow to iterate over data that comes asynchronously, on-demand.
|
| ValueState<T> |
State interface for partitioned single-value state. |