MCPcopy Create free account
hub / github.com/comnik/declarative-dataflow / main

Function main

experiments/src/bin/hector_wco.rs:8–132  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

6use Value::Eid;
7
8fn main() {
9 let filename = std::env::args().nth(1).unwrap();
10 let batching = std::env::args().nth(2).unwrap().parse::<usize>().unwrap();
11 let inspect = std::env::args().any(|x| x == "inspect");
12
13 timely::execute_from_args(std::env::args().skip(2), move |worker| {
14 let mut timer = std::time::Instant::now();
15 let graph = GraphMMap::new(&filename);
16 let mut server = Server::<u64, u64>::new(Default::default());
17
18 // [?a :edge ?b] [?b :edge ?c] [?a :edge ?c]
19 let (a, b, c) = (1, 2, 3);
20 // let plan = q(
21 // vec![a, b, c],
22 // vec![
23 // Binding::attribute(a, "edge", b),
24 // Binding::attribute(b, "edge", c),
25 // Binding::attribute(a, "edge", c),
26 // ],
27 // );
28
29 let plan = q(
30 vec![a, b, c],
31 vec![
32 Binding::attribute(a, "edge", b),
33 Binding::attribute(a, "edge", c),
34 Binding::attribute(b, "edge", c),
35 ],
36 );
37
38 // let plan = q(
39 // vec![a, b, c],
40 // vec![
41 // Binding::attribute(b, "edge", c),
42 // Binding::attribute(a, "edge", c),
43 // Binding::attribute(a, "edge", b),
44 // ],
45 // );
46
47 // ([?a ?b] [?b ?c]) [?a ?c]
48 // let plan = Plan::Join(Join {
49 // variables: vec![a],
50 // left_plan: Box::new(Plan::MatchA(a, "edge".to_string(), c)),
51 // right_plan: Box::new(Plan::Join(Join {
52 // variables: vec![b],
53 // left_plan: Box::new(Plan::MatchA(a, "edge".to_string(), b)),
54 // right_plan: Box::new(Plan::MatchA(b, "edge".to_string(), c)),
55 // }))
56 // });
57
58 // ([?a ?b] [?a ?c]) [?b ?c]
59 // let plan = Plan::Join(Join {
60 // variables: vec![b, c],
61 // left_plan: Box::new(Plan::MatchA(b, "edge".to_string(), c)),
62 // right_plan: Box::new(Plan::Join(Join {
63 // variables: vec![a],
64 // left_plan: Box::new(Plan::MatchA(a, "edge".to_string(), b)),
65 // right_plan: Box::new(Plan::MatchA(a, "edge".to_string(), c)),

Callers

nothing calls this directly

Calls 8

qFunction · 0.85
TxDataClass · 0.85
indexMethod · 0.80
test_singleMethod · 0.80
advance_domainMethod · 0.80
is_any_outdatedMethod · 0.80
transactMethod · 0.45

Tested by

no test coverage detected