docs(rstream-query): update readme, diag, add example

thi-ng · Apr 26, 2018 · ced200a · ced200a
1 parent 75f2af2
commit ced200a
Show file tree

Hide file tree

Showing 5 changed files with 653 additions and 320 deletions.
diff --git a/assets/rs-query1.dot b/assets/rs-query1.dot
@@ -2,68 +2,93 @@ digraph g {
 rankdir=LR;
 node[fontname=Inconsolata,fontsize=11,style=filled,fontcolor=white];
 edge[fontname=Inconsolata,fontsize=11];
-s0[label="S\n(Stream)", color=blue];
-s1[label="s", color=black];
-s2[label="in-s", color=black];
-s3[label="<noid>", color=gray];
-s4[label="london-raw\n(StreamSync)", color=red];
-s5[label="xform-2", color=black];
-s6[label="london", color=black];
-s7[label="sub-3", color=black];
-s8[label="<noid>", color=gray];
-s9[label="P\n(Stream)", color=blue];
-s10[label="p", color=black];
-s11[label="in-p", color=black];
-s12[label="<noid>", color=gray];
-s13[label="countries-raw\n(StreamSync)", color=red];
-s14[label="xform-0", color=black];
-s15[label="countries", color=black];
-s16[label="sub-1", color=black];
-s17[label="<noid>", color=gray];
-s18[label="O\n(Stream)", color=blue];
-s19[label="o", color=black];
-s20[label="in-o", color=black];
-s21[label="<noid>", color=gray];
-s22[label="ALL\n(Stream)", color=blue];
-s23[label="s", color=black];
-s24[label="in-s", color=black];
-s25[label="<noid>", color=gray];
-s26[label="p", color=black];
-s27[label="in-p", color=black];
-s28[label="<noid>", color=gray];
-s29[label="o", color=black];
-s30[label="in-o", color=black];
-s31[label="<noid>", color=gray];
-s7 -> s8;
-s6 -> s7;
-s5 -> s6[label="xform"];
-s4 -> s5[label="xform"];
-s3 -> s4[label="xform"];
-s2 -> s3;
-s1 -> s2[label="xform"];
-s0 -> s1[label="xform"];
-s16 -> s17;
-s15 -> s16;
-s14 -> s15[label="xform"];
-s13 -> s14[label="xform"];
-s12 -> s13[label="xform"];
+s0[label="S\n(Stream)", color="blue"];
+s1[label="P\n(Stream)", color="blue"];
+s2[label="p", color="black"];
+s3[label="in-p", color="black"];
+s4[label="<noid>", color="gray"];
+s5[label="query-0-raw\n(StreamSync)", color="red"];
+s6[label="xform-1", color="black"];
+s7[label="query-0", color="black"];
+s8[label="in-0", color="black"];
+s9[label="<noid>", color="gray"];
+s10[label="streamsync-6\n(StreamSync)", color="red"];
+s11[label="xform-7", color="black"];
+s12[label="sub-8", color="black"];
+s13[label="<noid>", color="gray"];
+s14[label="in-p", color="black"];
+s15[label="<noid>", color="gray"];
+s16[label="query-4-raw\n(StreamSync)", color="red"];
+s17[label="xform-5", color="black"];
+s18[label="query-4", color="black"];
+s19[label="in-2", color="black"];
+s20[label="<noid>", color="gray"];
+s21[label="p", color="black"];
+s22[label="in-a", color="black"];
+s23[label="<noid>", color="gray"];
+s24[label="query-2-raw\n(StreamSync)", color="red"];
+s25[label="xform-3", color="black"];
+s26[label="query-2", color="black"];
+s27[label="in-1", color="black"];
+s28[label="<noid>", color="gray"];
+s29[label="O\n(Stream)", color="blue"];
+s30[label="o", color="black"];
+s31[label="in-o", color="black"];
+s32[label="<noid>", color="gray"];
+s33[label="o", color="black"];
+s34[label="in-o", color="black"];
+s35[label="<noid>", color="gray"];
+s36[label="ALL\n(Stream)", color="blue"];
+s37[label="in-s", color="black"];
+s38[label="<noid>", color="gray"];
+s39[label="in-b", color="black"];
+s40[label="<noid>", color="gray"];
+s41[label="in-s", color="black"];
+s42[label="<noid>", color="gray"];
+s12 -> s13;
 s11 -> s12;
 s10 -> s11[label="xform"];
 s9 -> s10[label="xform"];
-s21 -> s13[label="xform"];
-s20 -> s21;
-s19 -> s20[label="xform"];
+s8 -> s9;
+s7 -> s8[label="xform"];
+s6 -> s7[label="xform"];
+s5 -> s6[label="xform"];
+s4 -> s5[label="xform"];
+s3 -> s4;
+s20 -> s10[label="xform"];
+s19 -> s20;
 s18 -> s19[label="xform"];
-s25 -> s13[label="xform"];
-s24 -> s25;
-s23 -> s24[label="xform"];
-s28 -> s4[label="xform"];
+s17 -> s18[label="xform"];
+s16 -> s17[label="xform"];
+s15 -> s16[label="xform"];
+s14 -> s15;
+s2 -> s3[label="xform"];
+s2 -> s14[label="xform"];
+s28 -> s10[label="xform"];
 s27 -> s28;
 s26 -> s27[label="xform"];
-s31 -> s4[label="xform"];
-s30 -> s31;
-s29 -> s30[label="xform"];
+s25 -> s26[label="xform"];
+s24 -> s25[label="xform"];
+s23 -> s24[label="xform"];
 s22 -> s23;
-s22 -> s26;
-s22 -> s29;
+s21 -> s22[label="xform"];
+s1 -> s2[label="xform"];
+s1 -> s21[label="xform"];
+s32 -> s5[label="xform"];
+s31 -> s32;
+s30 -> s31[label="xform"];
+s35 -> s16[label="xform"];
+s34 -> s35;
+s33 -> s34[label="xform"];
+s29 -> s30[label="xform"];
+s29 -> s33[label="xform"];
+s38 -> s5[label="xform"];
+s37 -> s38;
+s40 -> s24[label="xform"];
+s39 -> s40;
+s42 -> s16[label="xform"];
+s41 -> s42;
+s36 -> s37[label="xform"];
+s36 -> s39[label="xform"];
+s36 -> s41[label="xform"];
 }