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

extern crate timely;
extern crate timely_communication;

use timely::dataflow::operators::*;
use timely_communication::Configuration;
use timely::progress::timestamp::RootTimestamp;

fn main() {
    timely::execute(Configuration::Thread, |worker| {
        let (mut input, mut cap) = worker.dataflow(|scope| {
            let (input, stream) = scope.new_unordered_input();
            stream.inspect_batch(|t, x| println!("{:?} -> {:?}", t, x));
            input
        });

        for round in 0..10 {
            input.session(cap.clone()).give(round);
            cap = cap.delayed(&RootTimestamp::new(round + 1));
            worker.step();
        }
    }).unwrap();
}