| <?xml version="1.0" encoding="UTF-8" standalone="no"?> |
| |
| <!-- |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you under the Apache License, Version 2.0 (the |
| "License"); you may not use this file except in compliance |
| with the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, |
| software distributed under the License is distributed on an |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| KIND, either express or implied. See the License for the |
| specific language governing permissions and limitations |
| under the License. |
| --> |
| |
| <svg |
| xmlns:dc="http://purl.org/dc/elements/1.1/" |
| xmlns:cc="http://creativecommons.org/ns#" |
| xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" |
| xmlns:svg="http://www.w3.org/2000/svg" |
| xmlns="http://www.w3.org/2000/svg" |
| xmlns:sodipodi="http://sodipodi.sourceforge.net/DTD/sodipodi-0.dtd" |
| xmlns:inkscape="http://www.inkscape.org/namespaces/inkscape" |
| inkscape:version="1.0beta1 (d565813, 2019-09-28)" |
| sodipodi:docname="program_dataflow.svg" |
| id="svg2" |
| height="495.70895" |
| width="632.86151" |
| version="1.1"> |
| <sodipodi:namedview |
| inkscape:current-layer="g2989" |
| inkscape:window-maximized="0" |
| inkscape:window-y="23" |
| inkscape:window-x="0" |
| inkscape:cy="120.70756" |
| inkscape:cx="148.92077" |
| inkscape:zoom="4" |
| showgrid="false" |
| id="namedview104" |
| inkscape:window-height="1389" |
| inkscape:window-width="2146" |
| inkscape:pageshadow="2" |
| inkscape:pageopacity="0" |
| guidetolerance="10" |
| gridtolerance="10" |
| objecttolerance="10" |
| borderopacity="1" |
| inkscape:document-rotation="0" |
| bordercolor="#666666" |
| pagecolor="#ffffff" /> |
| <defs |
| id="defs4" /> |
| <metadata |
| id="metadata7"> |
| <rdf:RDF> |
| <cc:Work |
| rdf:about=""> |
| <dc:format>image/svg+xml</dc:format> |
| <dc:type |
| rdf:resource="http://purl.org/dc/dcmitype/StillImage" /> |
| <dc:title /> |
| </cc:Work> |
| </rdf:RDF> |
| </metadata> |
| <g |
| transform="translate(-24.15625,-20.40625)" |
| id="g2989" |
| style="opacity:1;stop-opacity:1"> |
| <text |
| x="571.35248" |
| y="45.804131" |
| id="text2991" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Source</text> |
| <text |
| x="25.304533" |
| y="37.765511" |
| id="text2993" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">DataStream</text> |
| <text |
| x="107.97513" |
| y="37.765511" |
| id="text2995" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000"><</text> |
| <text |
| x="116.22718" |
| y="37.765511" |
| id="text2997" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#5b9bd5">String</text> |
| <text |
| x="166.0396" |
| y="37.765511" |
| id="text2999" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">> </text> |
| <text |
| x="182.69376" |
| y="37.765511" |
| id="text3001" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">lines = </text> |
| <text |
| x="248.86023" |
| y="37.765511" |
| id="text3003" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">env.</text> |
| <text |
| x="282.01849" |
| y="37.765511" |
| id="text3005" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">addSource</text> |
| <text |
| x="356.58704" |
| y="37.765511" |
| id="text3007" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(</text> |
| <text |
| x="282.01849" |
| y="54.269619" |
| id="text3009" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#2f5597">new</text> |
| <text |
| x="315.17673" |
| y="54.269619" |
| id="text3011" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">FlinkKafkaConsumer</text> |
| <text |
| x="464.3139" |
| y="54.269619" |
| id="text3013" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000"><>(…));</text> |
| <text |
| x="25.304533" |
| y="87.277847" |
| id="text3015" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">DataStream</text> |
| <text |
| x="107.97513" |
| y="87.277847" |
| id="text3017" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000"><</text> |
| <text |
| x="116.22718" |
| y="87.277847" |
| id="text3019" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#5b9bd5">Event</text> |
| <text |
| x="157.78754" |
| y="87.277847" |
| id="text3021" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">> events = </text> |
| <text |
| x="248.86023" |
| y="87.277847" |
| id="text3023" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">lines.</text> |
| <text |
| x="298.52261" |
| y="87.277847" |
| id="text3025" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">map</text> |
| <text |
| x="323.57883" |
| y="87.277847" |
| id="text3027" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">((line) </text> |
| <text |
| x="389.7453" |
| y="87.277847" |
| id="text3029" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#2f5597">-</text> |
| <text |
| x="397.99738" |
| y="87.277847" |
| id="text3031" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#2f5597">></text> |
| <text |
| x="414.50146" |
| y="87.277847" |
| id="text3033" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">parse</text> |
| <text |
| x="456.06183" |
| y="87.277847" |
| id="text3035" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(line));</text> |
| <text |
| x="25.304533" |
| y="120.28607" |
| id="text3037" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">DataStream</text> |
| <text |
| x="107.97513" |
| y="120.28607" |
| id="text3039" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000"><</text> |
| <text |
| x="116.22718" |
| y="120.28607" |
| id="text3041" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#5b9bd5">Statistics</text> |
| <text |
| x="199.19786" |
| y="120.28607" |
| id="text3043" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">> stats = events</text> |
| <text |
| x="91.471016" |
| y="136.79018" |
| id="text3045" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">.</text> |
| <text |
| x="99.723068" |
| y="136.79018" |
| id="text3047" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">keyBy</text> |
| <text |
| x="141.13339" |
| y="136.41518" |
| id="text3049" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(</text> |
| <text |
| x="149.38544" |
| y="136.79018" |
| id="text3051" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#548235"><tspan |
| id="tspan104" |
| style="font-style:normal;font-variant:normal;font-weight:normal;font-stretch:normal;font-size:13.8034px;font-family:'Courier New';-inkscape-font-specification:'Courier New Normal';font-variant-ligatures:normal;font-variant-caps:normal;font-variant-numeric:normal;font-variant-east-asian:normal;fill:#333333">event</tspan><tspan |
| id="tspan106" |
| style="font-style:normal;font-variant:normal;font-weight:normal;font-stretch:normal;font-size:13.8034px;font-family:'Courier New';-inkscape-font-specification:'Courier New Normal';font-variant-ligatures:normal;font-variant-caps:normal;font-variant-numeric:normal;font-variant-east-asian:normal"> <tspan |
| id="tspan939" |
| style="fill:#1a1a1a">-> event.id</tspan></tspan></text> |
| <text |
| x="290.69376" |
| y="136.41518" |
| id="text3053" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">)</text> |
| <text |
| x="91.471016" |
| y="153.2943" |
| id="text3055" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">.</text> |
| <text |
| x="99.723068" |
| y="153.2943" |
| id="text3057" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">timeWindow</text> |
| <text |
| x="182.69376" |
| y="153.2943" |
| id="text3059" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(</text> |
| <text |
| x="190.94582" |
| y="153.2943" |
| id="text3061" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">Time.seconds</text> |
| <text |
| x="290.27054" |
| y="153.2943" |
| id="text3063" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(10))</text> |
| <text |
| x="91.471016" |
| y="169.79842" |
| id="text3065" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">.</text> |
| <text |
| x="99.723068" |
| y="169.79842" |
| id="text3067" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">apply</text> |
| <text |
| x="141.13339" |
| y="169.79842" |
| id="text3069" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(</text> |
| <text |
| x="149.38544" |
| y="169.79842" |
| id="text3071" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#2f5597">new</text> |
| <text |
| x="182.69376" |
| y="169.79842" |
| id="text3073" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">MyWindowAggregationFunction</text> |
| <text |
| x="406.24942" |
| y="169.79842" |
| id="text3075" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">());</text> |
| <text |
| x="25.304533" |
| y="202.2049" |
| id="text3077" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">stats.</text> |
| <text |
| x="74.816864" |
| y="202.62952" |
| id="text3079" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#843c0c">addSink</text> |
| <text |
| x="132.88133" |
| y="202.80663" |
| id="text3081" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(</text> |
| <text |
| x="141.13339" |
| y="202.16539" |
| id="text3083" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:bold;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#2f5597">new</text> |
| <text |
| x="174.4417" |
| y="202.19572" |
| id="text3085" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">MySink</text> |
| <text |
| x="221.16571" |
| y="202.05418" |
| id="text3087" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:13.8034px;font-family:'Courier New';text-align:start;text-anchor:start;fill:#000000">(...));</text> |
| <path |
| d="m 32.445583,379.40702 c 0,-17.70441 14.309815,-32.05174 31.957962,-32.05174 17.648146,0 31.957961,14.34733 31.957961,32.05174 0,17.68566 -14.309815,32.03298 -31.957961,32.03298 -17.648147,0 -31.957962,-14.34732 -31.957962,-32.03298" |
| id="path3089" |
| style="fill:#ffd966;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="46.974251" |
| y="383.34982" |
| id="text3091" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Source</text> |
| <path |
| d="m 170.44246,379.40702 c 0,-17.70441 14.34733,-32.05174 32.03298,-32.05174 17.70441,0 32.05174,14.34733 32.05174,32.05174 0,17.68566 -14.34733,32.03298 -32.05174,32.03298 -17.68565,0 -32.03298,-14.34732 -32.03298,-32.03298" |
| id="path3093" |
| style="fill:#ffd966;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="187.06161" |
| y="383.34982" |
| id="text3095" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">map()</text> |
| <path |
| d="m 104.1822,375.18722 h 50.16875 v -4.2198 l 8.43961,8.4396 -8.43961,8.4396 v -4.2198 H 104.1822 Z" |
| id="path3097" |
| style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 532.55767,21.023988 c 4.93248,0 8.90847,0.675168 8.90847,1.500373 v 17.49811 c 0,0.825205 3.99475,1.481619 8.90847,1.481619 -4.91372,0 -8.90847,0.675168 -8.90847,1.481619 v 17.516864 c 0,0.806451 -3.97599,1.481619 -8.90847,1.481619" |
| id="path3099" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 532.55767,70.573832 c 4.93248,0 8.90847,0.675168 8.90847,1.481619 v 9.771184 c 0,0.825206 3.99475,1.481619 8.90847,1.481619 -4.91372,0 -8.90847,0.675168 -8.90847,1.481619 v 9.771185 c 0,0.825205 -3.97599,1.481619 -8.90847,1.481619" |
| id="path3101" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 532.08881,104.65107 c 4.93248,0 8.90847,0.65641 8.90847,1.48162 v 33.83343 c 0,0.8252 3.99474,1.48162 8.90847,1.48162 -4.91373,0 -8.90847,0.67517 -8.90847,1.48162 v 33.85218 c 0,0.80645 -3.97599,1.48162 -8.90847,1.48162" |
| id="path3103" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 532.08881,188.2594 c 4.93248,0 8.90847,0.67517 8.90847,1.48162 v 9.62115 c 0,0.8252 3.99474,1.48162 8.90847,1.48162 -4.91373,0 -8.90847,0.65641 -8.90847,1.48161 v 9.62115 c 0,0.80645 -3.97599,1.48162 -8.90847,1.48162" |
| id="path3105" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="571.35248" |
| y="86.226501" |
| id="text3107" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Transformation</text> |
| <text |
| x="571.35248" |
| y="145.72234" |
| id="text3109" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Transformation</text> |
| <text |
| x="94.209488" |
| y="313.34818" |
| id="text3111" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Source</text> |
| <text |
| x="88.508072" |
| y="326.85153" |
| id="text3113" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Operator</text> |
| <path |
| d="m 242.17908,375.18722 h 50.16875 v -4.2198 l 8.4396,8.4396 -8.4396,8.4396 v -4.2198 h -50.16875 z" |
| id="path3115" |
| style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 308.43934,379.40702 c 0,-17.70441 14.34732,-32.05174 32.05173,-32.05174 17.68566,0 32.03299,14.34733 32.03299,32.05174 0,17.68566 -14.34733,32.03298 -32.03299,32.03298 -17.70441,0 -32.05173,-14.34732 -32.05173,-32.03298" |
| id="path3117" |
| style="fill:#ffd966;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="318.24503" |
| y="371.34683" |
| id="text3119" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">keyBy</text> |
| <text |
| x="349.15274" |
| y="371.34683" |
| id="text3121" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">()/</text> |
| <text |
| x="314.79416" |
| y="383.34982" |
| id="text3123" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">window()/</text> |
| <text |
| x="322.29605" |
| y="395.35281" |
| id="text3125" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">apply()</text> |
| <path |
| d="m 380.17596,375.18722 h 50.16875 v -4.2198 l 8.4396,8.4396 -8.4396,8.4396 v -4.2198 h -50.16875 z" |
| id="path3127" |
| style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 446.45497,379.40702 c 0,-17.70441 14.34733,-32.05174 32.03298,-32.05174 17.70441,0 32.03298,14.34733 32.03298,32.05174 0,17.68566 -14.32857,32.03298 -32.03298,32.03298 -17.68565,0 -32.03298,-14.34732 -32.03298,-32.03298" |
| id="path3129" |
| style="fill:#ffd966;fill-opacity:1;fill-rule:evenodd;stroke:none" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="467.4761" |
| y="383.34982" |
| id="text3131" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:10.0525px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Sink</text> |
| <path |
| d="m 240.45365,250.46865 h 17.01049 v -16.2603 h 33.98347 v 16.2603 h 16.99173 l -33.98347,16.24154 z" |
| id="path3133" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="227.00369" |
| y="313.34818" |
| id="text3135" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Transformation</text> |
| <text |
| x="242.00743" |
| y="326.85153" |
| id="text3137" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Operators</text> |
| <text |
| x="438.99158" |
| y="313.34818" |
| id="text3139" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Sink</text> |
| <text |
| x="426.08835" |
| y="326.85153" |
| id="text3141" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Operator</text> |
| <path |
| d="m 451.65002,333.72064 5.6264,8.21454 -1.03151,0.69393 -5.6264,-8.19579 z m 6.4516,6.11402 0.76895,5.53263 -4.89497,-2.70067 z" |
| id="path3143" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 89.591069,331.58261 -4.688668,8.04575 1.069017,0.63766 4.688668,-8.06451 z m -5.682665,6.02025 -0.356339,5.58889 4.669913,-3.07577 z" |
| id="path3145" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 234.03956,329.40706 -12.92197,12.80944 0.88147,0.88147 12.92196,-12.79068 z m -13.35333,10.59639 -1.80045,5.28882 5.32633,-1.74418 z" |
| id="path3147" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 301.21879,329.40706 15.51012,14.72242 -0.86272,0.90023 -15.51011,-14.72242 z m 15.88521,12.49062 1.91298,5.27006 -5.34509,-1.63166 z" |
| id="path3149" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 241.72897,447.91784 -87.19047,-54.5761 0.65641,-1.06902 87.20923,54.5761 z m -87.13421,-52.32554 -2.90697,-4.78244 5.57014,0.54389 z" |
| id="path3151" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="245.67148" |
| y="463.08081" |
| id="text3153" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Stream</text> |
| <path |
| d="m 291.37259,447.9741 102.90688,-49.34354 -0.54388,-1.12528 -102.90689,49.34354 z m 102.58806,-47.11174 3.41335,-4.4261 -5.5889,-0.0938 2.17555,4.51987 z" |
| id="path3155" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <path |
| d="m 270.77996,440.92234 v -39.79741 h -1.25656 v 39.79741 z m 1.87547,-38.54085 -2.49438,-5.00749 -2.51312,5.00749 z" |
| id="path3157" |
| style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.0187547px;stroke-linecap:butt;stroke-linejoin:round;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="571.35248" |
| y="205.12807" |
| id="text3159" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Sink</text> |
| <path |
| d="m 516.93503,463.33418 c 0,8.15828 -1.10652,14.75993 -2.45686,14.75993 H 273.33059 c -1.36909,0 -2.47561,6.62039 -2.47561,14.77868 0,-8.15829 -1.08777,-14.77868 -2.45687,-14.77868 H 27.250539 c -1.369091,0 -2.475617,-6.60165 -2.475617,-14.75993" |
| id="path3161" |
| style="fill:none;stroke:#000000;stroke-width:1.25656px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1" |
| inkscape:connector-curvature="0" /> |
| <text |
| x="214.03168" |
| y="513.79102" |
| id="text3163" |
| xml:space="preserve" |
| style="font-style:italic;font-weight:normal;font-size:11.2528px;font-family:Verdana;text-align:start;text-anchor:start;fill:#000000">Streaming Dataflow</text> |
| <text |
| x="-125.25892" |
| y="179.02612" |
| transform="translate(24.15625,20.40625)" |
| id="text3257" |
| xml:space="preserve" |
| style="font-style:normal;font-weight:normal;font-size:40px;line-height:125%;font-family:Sans;letter-spacing:0px;word-spacing:0px;fill:#000000;fill-opacity:1;stroke:none"><tspan |
| x="-125.25892" |
| y="179.02612" |
| id="tspan3259" /></text> |
| </g> |
| </svg> |
