timely/dataflow/operators/
mod.rs

1//! Extension traits for `Stream` implementing various operators.
2//!
3//! A collection of functions taking typed `Stream` objects as input and producing new `Stream`
4//! objects as output. Many of the operators provide simple, composable functionality. Some of the
5//! operators are more complicated, for use with advanced timely dataflow features.
6//!
7//! The [`Operator`](generic::operator) trait provides general
8//! operators whose behavior can be supplied using closures accepting input and output handles.
9//! Most of the operators in this module are defined using these two general operators.
10
11pub use self::enterleave::{Enter, EnterAt, Leave};
12pub use self::input::Input;
13pub use self::unordered_input::{UnorderedInput, UnorderedInputCore};
14pub use self::feedback::{Feedback, LoopVariable, ConnectLoop};
15pub use self::concat::{Concat, Concatenate};
16pub use self::partition::Partition;
17pub use self::map::Map;
18pub use self::inspect::{Inspect, InspectCore};
19pub use self::filter::Filter;
20pub use self::delay::Delay;
21pub use self::exchange::Exchange;
22pub use self::broadcast::Broadcast;
23pub use self::probe::Probe;
24pub use self::to_stream::{ToStream, ToStreamCore, ToStreamAsync, Event};
25pub use self::capture::Capture;
26pub use self::branch::{Branch, BranchWhen};
27pub use self::ok_err::OkErr;
28pub use self::result::ResultStream;
29
30pub use self::generic::Operator;
31pub use self::generic::{Notificator, FrontierNotificator};
32
33pub use self::reclock::Reclock;
34pub use self::count::Accumulate;
35
36pub mod enterleave;
37pub mod input;
38pub mod flow_controlled;
39pub mod unordered_input;
40pub mod feedback;
41pub mod concat;
42pub mod partition;
43pub mod map;
44pub mod inspect;
45pub mod filter;
46pub mod delay;
47pub mod exchange;
48pub mod broadcast;
49pub mod probe;
50pub mod to_stream;
51pub mod capture;
52pub mod branch;
53pub mod ok_err;
54pub mod rc;
55pub mod result;
56
57pub mod aggregation;
58pub mod generic;
59
60pub mod reclock;
61pub mod count;
62
63// keep "mint" module-private
64mod capability;
65pub use self::capability::{ActivateCapability, Capability, InputCapability, CapabilitySet, DowngradeError};
timely/dataflow/operators/mod.rs

timely/dataflow/operators/
mod.rs
