Expand description
State management for stateful stream processing.
Structs§
- Aggregating
State - Aggregating state.
- Broadcast
State - Broadcast state (shared across all parallel instances).
- Checkpoint
- In-memory checkpoint implementation.
- Checkpoint
Barrier - Checkpoint barrier.
- Checkpoint
Config - Checkpoint configuration.
- Checkpoint
Coordinator - Checkpoint coordinator.
- Checkpoint
Metadata - Checkpoint metadata.
- List
State - List state (stores a list of values per key).
- MapState
- Map state (stores key-value pairs per key).
- Memory
State Backend - In-memory state backend.
- Reducing
State - Reducing state.
- Union
List State - Union list state (list that is distributed across parallel instances).
- Value
State - Value state (stores a single value per key).
Traits§
- Checkpoint
Storage - Checkpoint storage.
- Keyed
State - Keyed state trait.
- List
Checkpointed - Trait for checkpointable list state.
- Operator
State - Operator state trait.
- State
Backend - Trait for state backends.