timely 0.2.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
18
19
20
21
22
23
24
25
26
27
28
29

extern crate timely;

use timely::dataflow::operators::*;

fn main() {
    timely::execute_from_args(std::env::args().skip(1), move |worker| {
        let index = worker.index();
        let peers = worker.peers();

        let mut input = worker.dataflow::<u64,_,_>(|scope| {

            let (input, stream) = scope.new_input();

            stream
                .broadcast()
                .inspect(move |x| println!("{} -> {:?}", index, x));

            input
        });

        for round in 0u64..10 {
            if (round as usize) % peers == index {
                input.send(round);
            }
            input.advance_to(round + 1);
            worker.step();
        }
    }).unwrap();
}