timely 0.5.0

A low-latency data-parallel dataflow system in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

//! Generic operators defined by user-provided closures.

pub mod unary;
pub mod binary;
pub mod operator;
pub mod builder_rc;
pub mod builder_raw;
// pub mod builder_ref;
mod handles;
mod notificator;

pub use self::handles::{InputHandle, FrontieredInputHandle, OutputHandle};
pub use self::notificator::{Notificator, FrontierNotificator};

pub use self::unary::Unary;
pub use self::binary::Binary;
pub use self::operator::{Operator, source};