dbsp 0.287.0

Continuous streaming analytics engine
Documentation
1
2
3
4
5
6
mod rolling_aggregate;
mod waterline;
mod window;

pub use crate::operator::dynamic::time_series::{Range, RelOffset, RelRange};
pub use rolling_aggregate::{OrdPartitionedIndexedZSet, OrdPartitionedOverStream};