This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new fabeb9f Revert "[hotfix][docs] Fix overlapping text" fabeb9f is described below commit fabeb9f5fd6e170a79aa7a43c492b049d384e509 Author: Robert Metzger <rmetz...@apache.org> AuthorDate: Mon Apr 20 11:26:15 2020 +0200 Revert "[hotfix][docs] Fix overlapping text" This reverts commit b8b0331247fe6d023d4da44868cb1f3526b62c62. The commit has removed a license header from the file, causing the apache rat check to fail. --- docs/fig/program_dataflow.svg | 1062 ++++++++++++++++++++--------------------- 1 file changed, 520 insertions(+), 542 deletions(-) diff --git a/docs/fig/program_dataflow.svg b/docs/fig/program_dataflow.svg index 4565de7..67ce157 100644 --- a/docs/fig/program_dataflow.svg +++ b/docs/fig/program_dataflow.svg @@ -1,39 +1,34 @@ <?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" + version="1.1" 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="149.91695" - inkscape:cx="371.40705" - inkscape:zoom="1.3289991" - showgrid="false" - id="namedview104" - inkscape:window-height="1441" - inkscape:window-width="1936" - inkscape:pageshadow="2" - inkscape:pageopacity="0" - guidetolerance="10" - gridtolerance="10" - objecttolerance="10" - borderopacity="1" - inkscape:document-rotation="0" - bordercolor="#666666" - pagecolor="#ffffff" /> + height="495.70895" + id="svg2"> <defs id="defs4" /> <metadata @@ -44,525 +39,508 @@ <dc:format>image/svg+xml</dc:format> <dc:type rdf:resource="http://purl.org/dc/dcmitype/StillImage" /> - <dc:title /> + <dc:title></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.79018" - 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">"id"</text> - <text - x="182.69376" - y="136.79018" - 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">BucketingSink</text> - <text - x="281.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">(path));</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 + transform="translate(-89.288343,-87.370121)" + id="layer1"> + <g + transform="translate(65.132093,66.963871)" + id="g2989"> + <text + x="571.35248" + y="45.804131" + id="text2991" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Source</text> + <text + x="25.304533" + y="37.765511" + id="text2993" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">DataStream</text> + <text + x="107.97513" + y="37.765511" + id="text2995" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New"><</text> + <text + x="116.22718" + y="37.765511" + id="text2997" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#5b9bd5;font-family:Courier New">String</text> + <text + x="166.0396" + y="37.765511" + id="text2999" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">> </text> + <text + x="182.69376" + y="37.765511" + id="text3001" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">lines = </text> + <text + x="248.86023" + y="37.765511" + id="text3003" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">env.</text> + <text + x="282.01849" + y="37.765511" + id="text3005" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">addSource</text> + <text + x="356.58704" + y="37.765511" + id="text3007" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(</text> + <text + x="282.01849" + y="54.269619" + id="text3009" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#2f5597;font-family:Courier New">new</text> + <text + x="315.17673" + y="54.269619" + id="text3011" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">FlinkKafkaConsumer</text> + <text + x="464.3139" + y="54.269619" + id="text3013" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New"><>(…));</text> + <text + x="25.304533" + y="87.277847" + id="text3015" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">DataStream</text> + <text + x="107.97513" + y="87.277847" + id="text3017" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New"><</text> + <text + x="116.22718" + y="87.277847" + id="text3019" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#5b9bd5;font-family:Courier New">Event</text> + <text + x="157.78754" + y="87.277847" + id="text3021" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">> events = </text> + <text + x="248.86023" + y="87.277847" + id="text3023" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">lines.</text> + <text + x="298.52261" + y="87.277847" + id="text3025" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">map</text> + <text + x="323.57883" + y="87.277847" + id="text3027" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">((line) </text> + <text + x="389.7453" + y="87.277847" + id="text3029" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#2f5597;font-family:Courier New">-</text> + <text + x="397.99738" + y="87.277847" + id="text3031" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#2f5597;font-family:Courier New">></text> + <text + x="414.50146" + y="87.277847" + id="text3033" + xml:space="preserve" + style="font-size:13.80343914px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">parse</text> + <text + x="456.06183" + y="87.277847" + id="text3035" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(line));</text> + <text + x="25.304533" + y="120.28607" + id="text3037" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">DataStream</text> + <text + x="107.97513" + y="120.28607" + id="text3039" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New"><</text> + <text + x="116.22718" + y="120.28607" + id="text3041" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#5b9bd5;font-family:Courier New">Statistics</text> + <text + x="199.19786" + y="120.28607" + id="text3043" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">> stats = events</text> + <text + x="91.471016" + y="136.79018" + id="text3045" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">.</text> + <text + x="99.723068" + y="136.79018" + id="text3047" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">keyBy</text> + <text + x="141.13339" + y="136.79018" + id="text3049" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(</text> + <text + x="149.38544" + y="136.79018" + id="text3051" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#548235;font-family:Courier New">"id"</text> + <text + x="182.69376" + y="136.79018" + id="text3053" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">)</text> + <text + x="91.471016" + y="153.2943" + id="text3055" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">.</text> + <text + x="99.723068" + y="153.2943" + id="text3057" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">timeWindow</text> + <text + x="182.69376" + y="153.2943" + id="text3059" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(</text> + <text + x="190.94582" + y="153.2943" + id="text3061" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">Time.seconds</text> + <text + x="290.27054" + y="153.2943" + id="text3063" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(10))</text> + <text + x="91.471016" + y="169.79842" + id="text3065" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">.</text> + <text + x="99.723068" + y="169.79842" + id="text3067" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">apply</text> + <text + x="141.13339" + y="169.79842" + id="text3069" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(</text> + <text + x="149.38544" + y="169.79842" + id="text3071" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#2f5597;font-family:Courier New">new</text> + <text + x="182.69376" + y="169.79842" + id="text3073" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">MyWindowAggregationFunction</text> + <text + x="406.24942" + y="169.79842" + id="text3075" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">());</text> + <text + x="25.304533" + y="202.80663" + id="text3077" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">stats.</text> + <text + x="74.816864" + y="202.80663" + id="text3079" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#843c0c;font-family:Courier New">addSink</text> + <text + x="132.88133" + y="202.80663" + id="text3081" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(</text> + <text + x="141.13339" + y="202.80663" + id="text3083" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:bold;text-align:start;text-anchor:start;fill:#2f5597;font-family:Courier New">new</text> + <text + x="174.4417" + y="202.80663" + id="text3085" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">BucketingSink</text> + <text + x="265.36435" + y="202.80663" + id="text3087" + xml:space="preserve" + style="font-size:13.80343914px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Courier New">(path));</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" /> + <text + x="46.974251" + y="383.34982" + id="text3091" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">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" /> + <text + x="187.06161" + y="383.34982" + id="text3095" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">map()</text> + <path + d="m 104.1822,375.18722 50.16875,0 0,-4.2198 8.43961,8.4396 -8.43961,8.4396 0,-4.2198 -50.16875,0 z" + id="path3097" + style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" /> + <path + d="m 532.55767,21.023988 c 4.93248,0 8.90847,0.675168 8.90847,1.500373 l 0,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 l 0,17.516864 c 0,0.806451 -3.97599,1.481619 -8.90847,1.481619" + id="path3099" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 532.55767,70.573832 c 4.93248,0 8.90847,0.675168 8.90847,1.481619 l 0,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 l 0,9.771185 c 0,0.825205 -3.97599,1.481619 -8.90847,1.481619" + id="path3101" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 532.08881,104.65107 c 4.93248,0 8.90847,0.65641 8.90847,1.48162 l 0,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 l 0,33.85218 c 0,0.80645 -3.97599,1.48162 -8.90847,1.48162" + id="path3103" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 532.08881,188.2594 c 4.93248,0 8.90847,0.67517 8.90847,1.48162 l 0,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 l 0,9.62115 c 0,0.80645 -3.97599,1.48162 -8.90847,1.48162" + id="path3105" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <text + x="571.35248" + y="86.226501" + id="text3107" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Transformation</text> + <text + x="571.35248" + y="145.72234" + id="text3109" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Transformation</text> + <text + x="94.209488" + y="313.34818" + id="text3111" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Source</text> + <text + x="88.508072" + y="326.85153" + id="text3113" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Operator</text> + <path + d="m 242.17908,375.18722 50.16875,0 0,-4.2198 8.4396,8.4396 -8.4396,8.4396 0,-4.2198 -50.16875,0 z" + id="path3115" + style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" /> + <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" /> + <text + x="318.24503" + y="371.34683" + id="text3119" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">keyBy</text> + <text + x="349.15274" + y="371.34683" + id="text3121" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">()/</text> + <text + x="314.79416" + y="383.34982" + id="text3123" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">window()/</text> + <text + x="322.29605" + y="395.35281" + id="text3125" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">apply()</text> + <path + d="m 380.17596,375.18722 50.16875,0 0,-4.2198 8.4396,8.4396 -8.4396,8.4396 0,-4.2198 -50.16875,0 z" + id="path3127" + style="fill:#bfbfbf;fill-opacity:1;fill-rule:evenodd;stroke:none" /> + <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" /> + <text + x="467.4761" + y="383.34982" + id="text3131" + xml:space="preserve" + style="font-size:10.05250454px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Sink</text> + <path + d="m 240.45365,250.46865 17.01049,0 0,-16.2603 33.98347,0 0,16.2603 16.99173,0 -33.98347,16.24154 z" + id="path3133" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <text + x="227.00369" + y="313.34818" + id="text3135" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Transformation</text> + <text + x="242.00743" + y="326.85153" + id="text3137" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Operators</text> + <text + x="438.99158" + y="313.34818" + id="text3139" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Sink</text> + <text + x="426.08835" + y="326.85153" + id="text3141" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Operator</text> + <path + d="m 451.65002,333.72064 5.6264,8.21454 -1.03151,0.69393 -5.6264,-8.19579 1.03151,-0.71268 z m 6.4516,6.11402 0.76895,5.53263 -4.89497,-2.70067 4.12602,-2.83196 z" + id="path3143" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 89.591069,331.58261 -4.688668,8.04575 1.069017,0.63766 4.688668,-8.06451 -1.069017,-0.6189 z m -5.682665,6.02025 -0.356339,5.58889 4.669913,-3.07577 -4.313574,-2.51312 z" + id="path3145" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 234.03956,329.40706 -12.92197,12.80944 0.88147,0.88147 12.92196,-12.79068 -0.88146,-0.90023 z m -13.35333,10.59639 -1.80045,5.28882 5.32633,-1.74418 -3.52588,-3.54464 z" + id="path3147" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 301.21879,329.40706 15.51012,14.72242 -0.86272,0.90023 -15.51011,-14.72242 0.86271,-0.90023 z m 15.88521,12.49062 1.91298,5.27006 -5.34509,-1.63166 3.43211,-3.6384 z" + id="path3149" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 241.72897,447.91784 -87.19047,-54.5761 0.65641,-1.06902 87.20923,54.5761 -0.67517,1.06902 z m -87.13421,-52.32554 -2.90697,-4.78244 5.57014,0.54389 -2.66317,4.23855 z" + id="path3151" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <text + x="245.67148" + y="463.08081" + id="text3153" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Stream</text> + <path + d="m 291.37259,447.9741 102.90688,-49.34354 -0.54388,-1.12528 -102.90689,49.34354 0.54389,1.12528 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.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <path + d="m 270.77996,440.92234 0,-39.79741 -1.25656,0 0,39.79741 1.25656,0 z m 1.87547,-38.54085 -2.49438,-5.00749 -2.51312,5.00749 5.0075,0 z" + id="path3157" + style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875467px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" /> + <text + x="571.35248" + y="205.12807" + id="text3159" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Sink</text> + <path + d="m 516.93503,463.33418 c 0,8.15828 -1.10652,14.75993 -2.45686,14.75993 l -241.14758,0 c -1.36909,0 -2.47561,6.62039 -2.47561,14.77868 0,-8.15829 -1.08777,-14.77868 -2.45687,-14.77868 l -241.147571,0 c -1.369091,0 -2.475617,-6.60165 -2.475617,-14.75993" + id="path3161" + style="fill:none;stroke:#000000;stroke-width:1.25656307px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" /> + <text + x="214.03168" + y="513.79102" + id="text3163" + xml:space="preserve" + style="font-size:11.2528038px;font-style:italic;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Streaming Dataflow</text> + <text x="-125.25892" y="179.02612" - id="tspan3259" /></text> + transform="translate(24.15625,20.40625)" + id="text3257" + xml:space="preserve" + style="font-size:40px;font-style:normal;font-weight:normal;line-height:125%;letter-spacing:0px;word-spacing:0px;fill:#000000;fill-opacity:1;stroke:none;font-family:Sans"><tspan + x="-125.25892" + y="179.02612" + id="tspan3259"></tspan></text> + </g> </g> </svg>