dbsp 0.287.0

Continuous streaming analytics engine
Documentation
1
2
3
4
5
6
7
8
9
10
//! Batch implementations that fall back from memory to disk.

#![allow(clippy::large_enum_variant)]

pub mod indexed_wset;
pub mod key_batch;
mod utils;
pub mod val_batch;
pub mod wset;
pub use utils::{pick_insert_destination, pick_merge_destination};