Skip to main content

oxigdal_streaming/state/
mod.rs

1//! State management for stateful stream processing.
2
3mod backend;
4mod checkpoint;
5mod keyed_state;
6mod operator_state;
7
8#[cfg(feature = "rocksdb-backend")]
9pub use backend::RocksDBStateBackend;
10pub use backend::{MemoryStateBackend, StateBackend};
11pub use checkpoint::{
12    Checkpoint, CheckpointBarrier, CheckpointConfig, CheckpointCoordinator, CheckpointMetadata,
13    CheckpointStorage,
14};
15pub use keyed_state::{
16    AggregatingState, KeyedState, ListState, MapState, ReducingState, ValueState,
17};
18pub use operator_state::{BroadcastState, ListCheckpointed, OperatorState, UnionListState};