| Interface | Description |
|---|---|
| AggregatingState<IN,OUT> |
State interface for aggregating state, based on an AggregateFunction. |
| 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> |
Extension of
AppendingState that allows merging of state. |
| 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. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.