You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
271 lines
5.8 KiB
271 lines
5.8 KiB
7 years ago
|
digraph UnclePhil {
|
||
|
|
kafka [color=gray, label="Kafka"];
|
||
|
|
|
||
|
|
selector1 [label="Selector"];
|
||
|
|
selector2 [label="Selector"];
|
||
|
|
selector3 [label="Selector"];
|
||
|
|
selector4 [label="Selector"];
|
||
|
|
selector5 [label="Selector"];
|
||
|
|
selector6 [label="Selector"];
|
||
|
|
selector7 [label="Selector"];
|
||
|
|
selector8 [label="Selector"];
|
||
|
|
selector9 [label="Selector"];
|
||
|
|
selector10 [label="Selector"];
|
||
|
|
selector11 [label="Selector"];
|
||
|
|
selector12 [label="Selector"];
|
||
|
|
|
||
|
|
process1 [label="ProcessMessages"];
|
||
|
|
process2 [label="ProcessMessages"];
|
||
|
|
process3 [label="ProcessMessages"];
|
||
|
|
process4 [label="ProcessMessages"];
|
||
|
|
process5 [label="ProcessMessages"];
|
||
|
|
process6 [label="ProcessMessages"];
|
||
|
|
process7 [label="ProcessMessages"];
|
||
|
|
process8 [label="ProcessMessages"];
|
||
|
|
process9 [label="ProcessMessages"];
|
||
|
|
process10 [label="ProcessMessages"];
|
||
|
|
process11 [label="ProcessMessages"];
|
||
|
|
process12 [label="ProcessMessages"];
|
||
|
|
|
||
|
|
splitter1 [label="MessageSpliter"];
|
||
|
|
splitter2 [label="MessageSpliter"];
|
||
|
|
splitter3 [label="MessageSpliter"];
|
||
|
|
splitter4 [label="MessageSpliter"];
|
||
|
|
splitter5 [label="MessageSpliter"];
|
||
|
|
splitter6 [label="MessageSpliter"];
|
||
|
|
splitter7 [label="MessageSpliter"];
|
||
|
|
splitter8 [label="MessageSpliter"];
|
||
|
|
splitter9 [label="MessageSpliter"];
|
||
|
|
splitter10 [label="MessageSpliter"];
|
||
|
|
splitter11 [label="MessageSpliter"];
|
||
|
|
splitter12 [label="MessageSpliter"];
|
||
|
|
|
||
|
|
extract1 [label="MetricExtractor"];
|
||
|
|
extract2 [label="MetricExtractor"];
|
||
|
|
extract3 [label="MetricExtractor"];
|
||
|
|
extract4 [label="MetricExtractor"];
|
||
|
|
extract5 [label="MetricExtractor"];
|
||
|
|
extract6 [label="MetricExtractor"];
|
||
|
|
extract7 [label="MetricExtractor"];
|
||
|
|
extract8 [label="MetricExtractor"];
|
||
|
|
extract9 [label="MetricExtractor"];
|
||
|
|
extract10 [label="MetricExtractor"];
|
||
|
|
extract11 [label="MetricExtractor"];
|
||
|
|
extract12 [label="MetricExtractor"];
|
||
|
|
|
||
|
|
keyby [label="keyBy/Hash"];
|
||
|
|
|
||
|
|
window1 [label="Window"];
|
||
|
|
window2 [label="Window"];
|
||
|
|
window3 [label="Window"];
|
||
|
|
window4 [label="Window"];
|
||
|
|
window5 [label="Window"];
|
||
|
|
window6 [label="Window"];
|
||
|
|
window7 [label="Window"];
|
||
|
|
window8 [label="Window"];
|
||
|
|
window9 [label="Window"];
|
||
|
|
window10 [label="Window"];
|
||
|
|
window11 [label="Window"];
|
||
|
|
window12 [label="Window"];
|
||
|
|
|
||
|
|
reduce1 [label="Reduce"];
|
||
|
|
reduce2 [label="Reduce"];
|
||
|
|
reduce3 [label="Reduce"];
|
||
|
|
reduce4 [label="Reduce"];
|
||
|
|
reduce5 [label="Reduce"];
|
||
|
|
reduce6 [label="Reduce"];
|
||
|
|
reduce7 [label="Reduce"];
|
||
|
|
reduce8 [label="Reduce"];
|
||
|
|
reduce9 [label="Reduce"];
|
||
|
|
reduce10 [label="Reduce"];
|
||
|
|
reduce11 [label="Reduce"];
|
||
|
|
reduce12 [label="Reduce"];
|
||
|
|
|
||
|
|
sink1 [label="Sink"];
|
||
|
|
sink2 [label="Sink"];
|
||
|
|
sink3 [label="Sink"];
|
||
|
|
sink4 [label="Sink"];
|
||
|
|
sink5 [label="Sink"];
|
||
|
|
sink6 [label="Sink"];
|
||
|
|
sink7 [label="Sink"];
|
||
|
|
sink8 [label="Sink"];
|
||
|
|
sink9 [label="Sink"];
|
||
|
|
sink10 [label="Sink"];
|
||
|
|
sink11 [label="Sink"];
|
||
|
|
sink12 [label="Sink"];
|
||
|
|
|
||
|
|
kafka -> selector1;
|
||
|
|
kafka -> selector2;
|
||
|
|
kafka -> selector3;
|
||
|
|
kafka -> selector4;
|
||
|
|
kafka -> selector5;
|
||
|
|
kafka -> selector6;
|
||
|
|
kafka -> selector7;
|
||
|
|
kafka -> selector8;
|
||
|
|
kafka -> selector9;
|
||
|
|
kafka -> selector10;
|
||
|
|
kafka -> selector11;
|
||
|
|
kafka -> selector12;
|
||
|
|
|
||
|
|
selector1 -> process1;
|
||
|
|
selector2 -> process2;
|
||
|
|
selector3 -> process3;
|
||
|
|
selector4 -> process4;
|
||
|
|
selector5 -> process5;
|
||
|
|
selector6 -> process6;
|
||
|
|
selector7 -> process7;
|
||
|
|
selector8 -> process8;
|
||
|
|
selector9 -> process9;
|
||
|
|
selector10 -> process10;
|
||
|
|
selector11 -> process11;
|
||
|
|
selector12 -> process12;
|
||
|
|
|
||
|
|
process1 -> splitter1;
|
||
|
|
process2 -> splitter2;
|
||
|
|
process3 -> splitter3;
|
||
|
|
process4 -> splitter4;
|
||
|
|
process5 -> splitter5;
|
||
|
|
process6 -> splitter6;
|
||
|
|
process7 -> splitter7;
|
||
|
|
process8 -> splitter8;
|
||
|
|
process9 -> splitter9;
|
||
|
|
process10 -> splitter10;
|
||
|
|
process11 -> splitter11;
|
||
|
|
process12 -> splitter12;
|
||
|
|
|
||
|
|
splitter1 -> extract1;
|
||
|
|
splitter1 -> extract1;
|
||
|
|
splitter1 -> extract1;
|
||
|
|
|
||
|
|
splitter2 -> extract2;
|
||
|
|
splitter2 -> extract2;
|
||
|
|
splitter2 -> extract2;
|
||
|
|
|
||
|
|
splitter3 -> extract3;
|
||
|
|
splitter3 -> extract3;
|
||
|
|
splitter3 -> extract3;
|
||
|
|
|
||
|
|
splitter4 -> extract4;
|
||
|
|
splitter4 -> extract4;
|
||
|
|
splitter4 -> extract4;
|
||
|
|
|
||
|
|
splitter5 -> extract5;
|
||
|
|
splitter5 -> extract5;
|
||
|
|
splitter5 -> extract5;
|
||
|
|
|
||
|
|
splitter6 -> extract6;
|
||
|
|
splitter6 -> extract6;
|
||
|
|
splitter6 -> extract6;
|
||
|
|
|
||
|
|
splitter7 -> extract7;
|
||
|
|
splitter7 -> extract7;
|
||
|
|
splitter7 -> extract7;
|
||
|
|
|
||
|
|
splitter8 -> extract8;
|
||
|
|
splitter8 -> extract8;
|
||
|
|
splitter8 -> extract8;
|
||
|
|
|
||
|
|
splitter9 -> extract9;
|
||
|
|
splitter9 -> extract9;
|
||
|
|
splitter9 -> extract9;
|
||
|
|
|
||
|
|
splitter10 -> extract10;
|
||
|
|
splitter10 -> extract10;
|
||
|
|
splitter10 -> extract10;
|
||
|
|
|
||
|
|
splitter11 -> extract11;
|
||
|
|
splitter11 -> extract11;
|
||
|
|
splitter11 -> extract11;
|
||
|
|
|
||
|
|
splitter12 -> extract12;
|
||
|
|
splitter12 -> extract12;
|
||
|
|
splitter12 -> extract12;
|
||
|
|
|
||
|
|
extract1 -> keyby;
|
||
|
|
extract1 -> keyby;
|
||
|
|
extract1 -> keyby;
|
||
|
|
|
||
|
|
extract2 -> keyby;
|
||
|
|
extract2 -> keyby;
|
||
|
|
extract2 -> keyby;
|
||
|
|
|
||
|
|
extract3 -> keyby;
|
||
|
|
extract3 -> keyby;
|
||
|
|
extract3 -> keyby;
|
||
|
|
|
||
|
|
extract4 -> keyby;
|
||
|
|
extract4 -> keyby;
|
||
|
|
extract4 -> keyby;
|
||
|
|
|
||
|
|
extract5 -> keyby;
|
||
|
|
extract5 -> keyby;
|
||
|
|
extract5 -> keyby;
|
||
|
|
|
||
|
|
extract6 -> keyby;
|
||
|
|
extract6 -> keyby;
|
||
|
|
extract6 -> keyby;
|
||
|
|
|
||
|
|
extract7 -> keyby;
|
||
|
|
extract7 -> keyby;
|
||
|
|
extract7 -> keyby;
|
||
|
|
|
||
|
|
extract8 -> keyby;
|
||
|
|
extract8 -> keyby;
|
||
|
|
extract8 -> keyby;
|
||
|
|
|
||
|
|
extract9 -> keyby;
|
||
|
|
extract9 -> keyby;
|
||
|
|
extract9 -> keyby;
|
||
|
|
|
||
|
|
extract10 -> keyby;
|
||
|
|
extract10 -> keyby;
|
||
|
|
extract10 -> keyby;
|
||
|
|
|
||
|
|
extract11 -> keyby;
|
||
|
|
extract11 -> keyby;
|
||
|
|
extract11 -> keyby;
|
||
|
|
|
||
|
|
extract12 -> keyby;
|
||
|
|
extract12 -> keyby;
|
||
|
|
extract12 -> keyby;
|
||
|
|
|
||
|
|
keyby -> window1;
|
||
|
|
keyby -> window2;
|
||
|
|
keyby -> window3;
|
||
|
|
keyby -> window4;
|
||
|
|
keyby -> window5;
|
||
|
|
keyby -> window6;
|
||
|
|
keyby -> window7;
|
||
|
|
keyby -> window8;
|
||
|
|
keyby -> window9;
|
||
|
|
keyby -> window10;
|
||
|
|
keyby -> window11;
|
||
|
|
keyby -> window12;
|
||
|
|
|
||
|
|
window1 -> reduce1;
|
||
|
|
window2 -> reduce2;
|
||
|
|
window3 -> reduce3;
|
||
|
|
window4 -> reduce4;
|
||
|
|
window5 -> reduce5;
|
||
|
|
window6 -> reduce6;
|
||
|
|
window7 -> reduce7;
|
||
|
|
window8 -> reduce8;
|
||
|
|
window9 -> reduce9;
|
||
|
|
window10 -> reduce10;
|
||
|
|
window11 -> reduce11;
|
||
|
|
window12 -> reduce12;
|
||
|
|
|
||
|
|
reduce1 -> sink1;
|
||
|
|
reduce2 -> sink2;
|
||
|
|
reduce3 -> sink3;
|
||
|
|
reduce4 -> sink4;
|
||
|
|
reduce5 -> sink5;
|
||
|
|
reduce6 -> sink6;
|
||
|
|
reduce7 -> sink7;
|
||
|
|
reduce8 -> sink8;
|
||
|
|
reduce9 -> sink9;
|
||
|
|
reduce10 -> sink10;
|
||
|
|
reduce11 -> sink11;
|
||
|
|
reduce12 -> sink12;
|
||
|
|
}
|