<?xml version="1.0" encoding="UTF-8"?>
<Diagram>
  <ID>JAVA</ID>
  <OriginalElement>org.apache.flink.util.Collector</OriginalElement>
  <nodes>
    <node x="2465.75" y="178.0">org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger.WriterCollector</node>
    <node x="2201.75" y="178.0">org.apache.flink.runtime.iterative.io.WorksetUpdateOutputCollector</node>
    <node x="778.75" y="178.0">org.apache.flink.runtime.operators.chaining.ChainedDriver</node>
    <node x="1376.0" y="277.0">org.apache.flink.runtime.operators.NoOpChainedDriver</node>
    <node x="1112.75" y="178.0">org.apache.flink.runtime.operators.shipping.OutputCollector</node>
    <node x="1129.0" y="277.0">org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver</node>
    <node x="849.0" y="277.0">org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver</node>
    <node x="1588.75" y="178.0">org.apache.flink.runtime.iterative.io.SolutionSetObjectsUpdateOutputCollector</node>
    <node x="214.0" y="277.0">org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver</node>
    <node x="1566.0" y="277.0">org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver</node>
    <node x="932.75" y="178.0">org.apache.flink.runtime.operators.util.metrics.CountingCollector</node>
    <node x="1532.5" y="79.0">org.apache.flink.util.Collector</node>
    <node x="596.0" y="277.0">org.apache.flink.runtime.operators.chaining.ChainedReduceCombineDriver</node>
    <node x="416.0" y="277.0">org.apache.flink.runtime.operators.chaining.ChainedMapDriver</node>
    <node x="0.0" y="277.0">org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver</node>
    <node x="1541.5" y="0.0">org.apache.flink.annotation.Public</node>
    <node x="1918.75" y="178.0">org.apache.flink.runtime.iterative.io.SolutionSetUpdateOutputCollector</node>
    <node x="1279.75" y="178.0">org.apache.flink.runtime.iterative.io.SolutionSetFastUpdateOutputCollector</node>
  </nodes>
  <notes />
  <edges>
    <edge source="org.apache.flink.runtime.operators.NoOpChainedDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="1461.0" y="237.0" />
      <point x="887.625" y="237.0" />
      <point x="41.875" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.iterative.io.SolutionSetUpdateOutputCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="2050.25" y="148.0" />
      <point x="1603.3125" y="148.0" />
      <point x="19.3125" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="1701.0" y="227.0" />
      <point x="904.375" y="227.0" />
      <point x="58.625" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger.WriterCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="2536.25" y="128.0" />
      <point x="1629.0625" y="128.0" />
      <point x="45.0625" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.GroupCombineChainedDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="1242.5" y="247.0" />
      <point x="870.875" y="247.0" />
      <point x="25.125" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.util.metrics.CountingCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="1012.75" y="138.0" />
      <point x="1551.8125" y="138.0" />
      <point x="-32.1875" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedDriver" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="845.75" y="128.0" />
      <point x="1538.9375" y="128.0" />
      <point x="-45.0625" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.iterative.io.SolutionSetFastUpdateOutputCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="1424.25" y="158.0" />
      <point x="1577.5625" y="158.0" />
      <point x="-6.4375" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="305.0" y="237.0" />
      <point x="803.875" y="237.0" />
      <point x="-41.875" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.iterative.io.SolutionSetObjectsUpdateOutputCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="1743.75" y="158.0" />
      <point x="1590.4375" y="158.0" />
      <point x="6.4375" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedMapDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="496.0" y="247.0" />
      <point x="820.625" y="247.0" />
      <point x="-25.125" y="14.5" />
    </edge>
    <edge source="org.apache.flink.util.Collector" target="org.apache.flink.annotation.Public">
      <point x="0.0" y="-14.5" />
      <point x="0.0" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.iterative.io.WorksetUpdateOutputCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="2323.75" y="138.0" />
      <point x="1616.1875" y="138.0" />
      <point x="32.1875" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedReduceCombineDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="712.5" y="257.0" />
      <point x="837.375" y="257.0" />
      <point x="-8.375" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedTerminationCriterionDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="979.0" y="257.0" />
      <point x="854.125" y="257.0" />
      <point x="8.375" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.shipping.OutputCollector" target="org.apache.flink.util.Collector">
      <point x="0.0" y="-14.5" />
      <point x="1186.25" y="148.0" />
      <point x="1564.6875" y="148.0" />
      <point x="-19.3125" y="14.5" />
    </edge>
    <edge source="org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver" target="org.apache.flink.runtime.operators.chaining.ChainedDriver">
      <point x="0.0" y="-14.5" />
      <point x="97.0" y="227.0" />
      <point x="787.125" y="227.0" />
      <point x="-58.625" y="14.5" />
    </edge>
  </edges>
  <settings layout="Hierarchic Group" zoom="0.7148838979824896" x="1303.4999999999998" y="153.0" />
  <SelectedNodes />
  <Categories>
    <Category>Inner Classes</Category>
  </Categories>
  <SCOPE>All</SCOPE>
  <VISIBILITY>private</VISIBILITY>
</Diagram>

