digraph G { id="graph_1036"; subgraph graph_stage_1036 { id="graph_stage_1036"; isCluster="true"; label="Stage 1036"; 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}"]; 1540 [id="node_1540" labelType="html" label="MapPartitionsRDD [1540] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1541 [id="node_1541" labelType="html" label="MapPartitionsRDD [1541] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1542 [id="node_1542" labelType="html" label="MapPartitionsRDD [1542] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3902 { id="cluster_3902"; isCluster="true"; label="WholeStageCodegen (14)"; 1543 [id="node_1543" labelType="html" label="MapPartitionsRDD [1543] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3901 { id="cluster_3901"; isCluster="true"; label="Exchange"; 1544 [id="node_1544" labelType="html" label="MapPartitionsRDD [1544] [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; 1539->1540; 1540->1541; 1541->1542; 1542->1543; 1543->1544; }