oxigdal-streaming 0.1.4

Real-time data processing and streaming pipelines for OxiGDAL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! State management for stateful stream processing.

mod backend;
mod checkpoint;
mod keyed_state;
mod operator_state;

#[cfg(feature = "rocksdb-backend")]
pub use backend::RocksDBStateBackend;
pub use backend::{MemoryStateBackend, StateBackend};
pub use checkpoint::{
    Checkpoint, CheckpointBarrier, CheckpointConfig, CheckpointCoordinator, CheckpointMetadata,
    CheckpointStorage,
};
pub use keyed_state::{
    AggregatingState, KeyedState, ListState, MapState, ReducingState, ValueState,
};
pub use operator_state::{BroadcastState, ListCheckpointed, OperatorState, UnionListState};