dbsp 0.287.0

Continuous streaming analytics engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

mod partitioned;
mod radix_tree;
mod range;
mod rolling_aggregate;
mod waterline;
mod window;

pub use partitioned::{
    OrdPartitionedIndexedZSet, PartitionCursor, PartitionedBatch, PartitionedBatchReader,
    PartitionedIndexedZSet,
};
pub use radix_tree::TreeNode;
pub use range::{Range, RelOffset, RelRange};
pub use rolling_aggregate::{
    OrdPartitionedOverStream, PartitionedRollingAggregateFactories,
    PartitionedRollingAggregateLinearFactories, PartitionedRollingAggregateWithWaterlineFactories,
    PartitionedRollingAverageFactories,
};
pub use waterline::LeastUpperBoundFunc;