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;
}
1487,1488
1491,1492
1504,1505
1518,1519
1522,1523
1510
1492
1500
1501
1502
1505
1506
1507
1508
1509
1510
1511
1512
1513
1523
1524
1525
1526
1527
1528