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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

pub(crate) mod batch_filter;
pub mod fallback;
pub mod file;
pub(crate) mod key_range;
pub mod merge_batcher;
pub mod vec;

pub use batch_filter::{BatchFilterStats, BatchFilters};
pub use fallback::{
    indexed_wset::{
        FallbackIndexedWSet, FallbackIndexedWSet as OrdIndexedWSet, FallbackIndexedWSetBuilder,
        FallbackIndexedWSetBuilder as OrdIndexedWSetBuilder, FallbackIndexedWSetFactories,
        FallbackIndexedWSetFactories as OrdIndexedWSetFactories,
    },
    key_batch::{
        FallbackKeyBatch, FallbackKeyBatch as OrdKeyBatch, FallbackKeyBatchFactories,
        FallbackKeyBatchFactories as OrdKeyBatchFactories,
    },
    val_batch::{
        FallbackValBatch, FallbackValBatch as OrdValBatch, FallbackValBatchFactories,
        FallbackValBatchFactories as OrdValBatchFactories,
    },
    wset::{
        FallbackWSet, FallbackWSet as OrdWSet, FallbackWSetBuilder,
        FallbackWSetBuilder as OrdWSetBuilder, FallbackWSetFactories,
        FallbackWSetFactories as OrdWSetFactories,
    },
};
pub use file::{
    FileIndexedWSet, FileIndexedWSetFactories, FileKeyBatch, FileKeyBatchFactories, FileValBatch,
    FileValBatchFactories, FileWSet, FileWSetFactories,
};
pub use vec::{
    VecIndexedWSet, VecIndexedWSetFactories, VecKeyBatch, VecKeyBatchFactories, VecValBatch,
    VecValBatchFactories, VecWSet, VecWSetFactories,
};