digraph G { id="graph_1034"; subgraph graph_stage_1034 { id="graph_stage_1034"; isCluster="true"; label="Stage 1034"; 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}"]; 1511 [id="node_1511" labelType="html" label="MapPartitionsRDD [1511] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1512 [id="node_1512" labelType="html" label="MapPartitionsRDD [1512] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1513 [id="node_1513" labelType="html" label="MapPartitionsRDD [1513] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3977 { id="cluster_3977"; isCluster="true"; label="Exchange"; 1519 [id="node_1519" labelType="html" label="ShuffledRowRDD [1519] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3974 { id="cluster_3974"; isCluster="true"; label="WholeStageCodegen (3)"; 1520 [id="node_1520" labelType="html" label="MapPartitionsRDD [1520] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3986 { id="cluster_3986"; isCluster="true"; label="Exchange"; 1523 [id="node_1523" labelType="html" label="ShuffledRowRDD [1523] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3983 { id="cluster_3983"; isCluster="true"; label="WholeStageCodegen (5)"; 1524 [id="node_1524" labelType="html" label="MapPartitionsRDD [1524] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3970 { id="cluster_3970"; isCluster="true"; label="WholeStageCodegen (6)"; 1525 [id="node_1525" labelType="html" label="ZippedPartitionsRDD2 [1525] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1526 [id="node_1526" labelType="html" label="MapPartitionsRDD [1526] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3929 { id="cluster_3929"; isCluster="true"; label="Union"; 1527 [id="node_1527" labelType="html" label="UnionRDD [1527] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_3928 { id="cluster_3928"; isCluster="true"; label="Exchange"; 1528 [id="node_1528" labelType="html" label="MapPartitionsRDD [1528] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1488->1489; 1492->1500; 1489->1501; 1500->1501; 1501->1502; 1505->1506; 1502->1507; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1510->1511; 1511->1512; 1512->1513; 1519->1520; 1523->1524; 1520->1525; 1524->1525; 1525->1526; 1513->1527; 1526->1527; 1527->1528; }