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
//! Abstractions for timely dataflow programming. //! //! Timely dataflow programs are constructed by manipulating [`Stream`](./stream/index.html) objects, //! most often using pre-defined [operators](./operators/index.html) that implement known patterns. //! //! # Examples //! ``` //! use timely::dataflow::operators::{ToStream, Inspect}; //! //! timely::example(|scope| { //! (0..10).to_stream(scope) //! .inspect(|x| println!("seen: {:?}", x)); //! }); //! ``` pub use self::stream::Stream; pub use self::scopes::{Scope, ScopeParent}; pub use self::operators::input::Handle as InputHandle; pub use self::operators::probe::Handle as ProbeHandle; pub mod operators; pub mod channels; pub mod scopes; pub mod stream;