digraph G { id="graph_1141"; subgraph graph_stage_1141 { id="graph_stage_1141"; isCluster="true"; label="Stage 1141"; subgraph cluster_3922 { id="cluster_3922"; isCluster="true"; label="Exchange"; 1481 [id="node_1481" labelType="html" label="ShuffledRowRDD [1481] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3919 { id="cluster_3919"; isCluster="true"; label="WholeStageCodegen (1)"; 1482 [id="node_1482" labelType="html" label="MapPartitionsRDD [1482] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3947 { id="cluster_3947"; isCluster="true"; label="Exchange"; 1488 [id="node_1488" labelType="html" label="ShuffledRowRDD [1488] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3944 { id="cluster_3944"; isCluster="true"; label="WholeStageCodegen (2)"; 1489 [id="node_1489" labelType="html" label="MapPartitionsRDD [1489] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3956 { id="cluster_3956"; isCluster="true"; label="Exchange"; 1492 [id="node_1492" labelType="html" label="ShuffledRowRDD [1492] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3953 { id="cluster_3953"; isCluster="true"; label="WholeStageCodegen (4)"; 1500 [id="node_1500" labelType="html" label="MapPartitionsRDD [1500] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3935 { id="cluster_3935"; isCluster="true"; label="WholeStageCodegen (5)"; 1501 [id="node_1501" labelType="html" label="ZippedPartitionsRDD2 [1501] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1502 [id="node_1502" labelType="html" label="MapPartitionsRDD [1502] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3965 { id="cluster_3965"; isCluster="true"; label="Exchange"; 1505 [id="node_1505" labelType="html" label="ShuffledRowRDD [1505] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3962 { id="cluster_3962"; isCluster="true"; label="WholeStageCodegen (7)"; 1506 [id="node_1506" labelType="html" label="MapPartitionsRDD [1506] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3931 { id="cluster_3931"; isCluster="true"; label="WholeStageCodegen (8)"; 1507 [id="node_1507" labelType="html" label="ZippedPartitionsRDD2 [1507] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1508 [id="node_1508" labelType="html" label="MapPartitionsRDD [1508] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3930 { id="cluster_3930"; isCluster="true"; label="InMemoryTableScan"; 1509 [id="node_1509" labelType="html" label="MapPartitionsRDD [1509] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1510 [id="node_1510" labelType="html" label="*(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, cachedQty#24452 AS qty#24454, demandChannel#24447, demandStream#24448, cachedKpis#24453 AS kpis#24455]\n+- *(8) SortMergeJoin [worklistShardItemId#446L, shardId#445], [cachedWorklistShardItemId#24451L, cachedShardId#24450], Inner\n :- *(5) Sort [worklistShardItemId#446L ASC NULLS FIRST, shardId#445 ASC NULLS FIRST], false, 0\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449])\n : +- *(5) HashAggregate(keys=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448], functions=[], output=[plant#449, shardId#445, version#447, worklistShardItemId#446L, product#448])\n : +- *(5) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449]\n : +- *(5) SortMergeJoin [worklistShardItemId#446L, shardId#445]... [1510] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1529 [id="node_1529" labelType="html" label="ShuffledRowRDD [1529] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3925 { id="cluster_3925"; isCluster="true"; label="WholeStageCodegen (7)"; 1530 [id="node_1530" labelType="html" label="MapPartitionsRDD [1530] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3911 { id="cluster_3911"; isCluster="true"; label="WholeStageCodegen (8)"; 1531 [id="node_1531" labelType="html" label="ZippedPartitionsRDD2 [1531] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1532 [id="node_1532" labelType="html" label="MapPartitionsRDD [1532] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3998 { id="cluster_3998"; isCluster="true"; label="InMemoryTableScan"; 1533 [id="node_1533" labelType="html" label="MapPartitionsRDD [1533] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1534 [id="node_1534" labelType="html" label="MapPartitionsRDD [1534] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1535 [id="node_1535" labelType="html" label="MapPartitionsRDD [1535] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3995 { id="cluster_3995"; isCluster="true"; label="WholeStageCodegen (9)"; 1536 [id="node_1536" labelType="html" label="MapPartitionsRDD [1536] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3910 { id="cluster_3910"; isCluster="true"; label="Union"; 1537 [id="node_1537" labelType="html" label="UnionRDD [1537] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3909 { id="cluster_3909"; isCluster="true"; label="InMemoryTableScan"; 1538 [id="node_1538" labelType="html" label="MapPartitionsRDD [1538] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1539 [id="node_1539" labelType="html" label="Union\n:- *(8) Project [shardId#445, worklistShardItemId#446L, version#447, product#448, plant#449, qty#452, null AS demandChannel#24687, null AS demandStream#24688, [] AS kpis#24722, true AS isNewlyCalculated#24690]\n: +- *(8) SortMergeJoin [coalesce(shardId#445, ), isnull(shardId#445), coalesce(worklistShardItemId#446L, 0), isnull(worklistShardItemId#446L), coalesce(version#447, 0), isnull(version#447), coalesce(product#448, ), isnull(product#448), coalesce(plant#449, ), isnull(plant#449), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#452, 0.0))), isnull(qty#452)], [coalesce(shardId#24679, ), isnull(shardId#24679), coalesce(worklistShardItemId#24680L, 0), isnull(worklistShardItemId#24680L), coalesce(version#24681, 0), isnull(version#24681), coalesce(product#24682, ), isnull(product#24682), coalesce(plant#24683, ), isnull(plant#24683), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#24454, 0.0))), isnull(qty#24454)], LeftAnti\n: :- *(1) Sort [coalesce(shardId#445, ) ASC NUL... [1539] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4225 { id="cluster_4225"; isCluster="true"; label="Exchange"; 1643 [id="node_1643" labelType="html" label="ShuffledRowRDD [1643] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4222 { id="cluster_4222"; isCluster="true"; label="WholeStageCodegen (8)"; 1644 [id="node_1644" labelType="html" label="MapPartitionsRDD [1644] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4221 { id="cluster_4221"; isCluster="true"; label="SortAggregate"; 1645 [id="node_1645" labelType="html" label="MapPartitionsRDD [1645] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4220 { id="cluster_4220"; isCluster="true"; label="InMemoryTableScan"; 1646 [id="node_1646" labelType="html" label="MapPartitionsRDD [1646] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1647 [id="node_1647" labelType="html" label="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)], output=[shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27425])\n+- *(8) Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]\n +- SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)], output=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502])\n +- *(7) Sort [demandChannel#272... [1647] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4385 { id="cluster_4385"; isCluster="true"; label="InMemoryTableScan"; 1677 [id="node_1677" labelType="html" label="MapPartitionsRDD [1677] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1678 [id="node_1678" labelType="html" label="MapPartitionsRDD [1678] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1679 [id="node_1679" labelType="html" label="MapPartitionsRDD [1679] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4381 { id="cluster_4381"; isCluster="true"; label="WholeStageCodegen (1)"; 1680 [id="node_1680" labelType="html" label="MapPartitionsRDD [1680] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4389 { id="cluster_4389"; isCluster="true"; label="InMemoryTableScan"; 1681 [id="node_1681" labelType="html" label="MapPartitionsRDD [1681] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1682 [id="node_1682" labelType="html" label="MapPartitionsRDD [1682] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1683 [id="node_1683" labelType="html" label="MapPartitionsRDD [1683] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4386 { id="cluster_4386"; isCluster="true"; label="WholeStageCodegen (2)"; 1684 [id="node_1684" labelType="html" label="MapPartitionsRDD [1684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4380 { id="cluster_4380"; isCluster="true"; label="Union"; 1685 [id="node_1685" labelType="html" label="UnionRDD [1685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4379 { id="cluster_4379"; isCluster="true"; label="Exchange"; 1686 [id="node_1686" labelType="html" label="MapPartitionsRDD [1686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1481->1482; 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1529->1530; 1482->1531; 1530->1531; 1531->1532; 1510->1533; 1533->1534; 1534->1535; 1535->1536; 1532->1537; 1536->1537; 1537->1538; 1538->1539; 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1539->1677; 1677->1678; 1678->1679; 1679->1680; 1647->1681; 1681->1682; 1682->1683; 1683->1684; 1680->1685; 1684->1685; 1685->1686; }