dbsp 0.287.0

Continuous streaming analytics engine
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
mod accumulate_trace_balanced;
mod balancer;
mod maxsat;
mod rebalancing_accumulator;

#[cfg(test)]
mod test;

pub use accumulate_trace_balanced::FlushState;
pub use balancer::{
    BALANCE_TAX, Balancer, BalancerError, BalancerHint, BalancerHints, JoinConstraint,
    KEY_DISTRIBUTION_REFRESH_THRESHOLD, MIN_ABSOLUTE_IMPROVEMENT_THRESHOLD,
    MIN_RELATIVE_IMPROVEMENT_THRESHOLD, PartitioningPolicy,
};
pub use maxsat::MaxSat;