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
37
38
39
40
41
42
43
44
45

use crate::{
    algebra::{OrdIndexedZSet, OrdIndexedZSetFactories, OrdZSet, OrdZSetFactories},
    dynamic::DynData,
};

mod accumulate_trace;
pub mod accumulator;
pub mod aggregate;
pub mod asof_join;
pub mod balance;
mod communication;
pub mod concat;
mod consolidate;
pub mod controlled_filter;
pub mod count;
pub mod distinct;
pub mod filter_map;
pub mod group;
pub mod index;
pub mod input;
pub(crate) mod input_upsert;
pub mod join;
pub mod join_range;
pub mod multijoin;
pub mod neighborhood;
pub mod outer_join;
mod output;
pub mod recursive;
pub mod sample;
mod saturate;
pub mod semijoin;
pub mod time_series;
pub mod trace;
pub(crate) mod upsert;

/// The "standard" indexed Z-set type used by monomorphic
/// versions of operators.
pub type MonoIndexedZSet = OrdIndexedZSet<DynData, DynData>;

/// The "standard" Z-set type used by monomorphic
/// versions of operators.
pub type MonoZSet = OrdZSet<DynData>;

pub type MonoIndexedZSetFactories = OrdIndexedZSetFactories<DynData, DynData>;
pub type MonoZSetFactories = OrdZSetFactories<DynData>;