oxigdal-streaming 0.1.7

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
19
20

//! State management for stateful stream processing.

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

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