hydroflow 0.10.0

Hydro's low-level dataflow runtime and IR
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use std::cell::RefCell;
use std::rc::Rc;

use hydroflow::hydroflow_syntax;
use hydroflow::scheduled::graph::Hydroflow;
use hydroflow::util::multiset::HashMultiSet;

pub fn main() {
    let output = Rc::new(RefCell::new(
        HashMultiSet::<(usize, usize, usize)>::default(),
    ));

    let mut df: Hydroflow = {
        let output = output.clone();
        hydroflow_syntax! {
            source_iter(0..2) -> [0]cj;
            source_iter(0..2) -> [1]cj;
            source_iter(0..2) -> [2]cj;

            cj = import!("triple_cross_join.hf")
                -> for_each(|x| output.borrow_mut().insert(x));
        }
    };

    println!(
        "{}",
        df.meta_graph().unwrap().to_mermaid(&Default::default())
    );

    df.run_available();

    #[rustfmt::skip]
    assert_eq!(
        *output.borrow(),
        HashMultiSet::from_iter([
            (0, 0, 0),
            (0, 0, 1),
            (0, 1, 0),
            (0, 1, 1),
            (1, 0, 0),
            (1, 0, 1),
            (1, 1, 0),
            (1, 1, 1),
        ])
    );
}

#[test]
fn test() {
    main();
}