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)); });
Reexports
pub use self::stream::Stream; |
pub use self::scopes::Scope; |
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. |