Module timely::dataflow
[−]
[src]
Abstractions for timely dataflow programming.
Timely dataflow programs are constructed by manipulating Stream
objects,
most often using pre-defined operators that implement known patterns.
#Examples
use timely::dataflow::operators::{ToStream, Inspect}; timely::example(|scope| { (0..10).to_stream(scope) .inspect(|x| println!("seen: {:?}", x)); });
Re-exports
pub use self::stream::Stream; |
pub use self::scopes::Scope; |
pub use self::scopes::ScopeParent; |
pub use self::operators::input::Handle as InputHandle; |
pub use self::operators::probe::Handle as ProbeHandle; |
Modules
channels |
Structured communication between timely dataflow operators. |
operators |
Extension traits for |
scopes |
Hierarchical organization of timely dataflow graphs. |
stream |
A handle to a typed stream of timely data. |