digraph G {
id="graph_1073";
subgraph graph_stage_1073 {
id="graph_stage_1073";
isCluster="true";
label="Stage 1073";
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_4274 {
id="cluster_4274";
isCluster="true";
label="InMemoryTableScan";
1629 [id="node_1629" labelType="html" label="MapPartitionsRDD [1629] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
1630 [id="node_1630" labelType="html" label="MapPartitionsRDD [1630] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
1631 [id="node_1631" labelType="html" label="MapPartitionsRDD [1631] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_4269 {
id="cluster_4269";
isCluster="true";
label="WholeStageCodegen (4)";
1632 [id="node_1632" labelType="html" label="MapPartitionsRDD [1632] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_4268 {
id="cluster_4268";
isCluster="true";
label="Exchange";
1633 [id="node_1633" labelType="html" label="MapPartitionsRDD [1633] [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->1629;
1629->1630;
1630->1631;
1631->1632;
1632->1633;
}
1480,1481
1487,1488
1491,1492
1504,1505
1528,1529
1510
1539
1492
1500
1501
1502
1505
1506
1507
1508
1509
1510
1529
1530
1531
1532
1533
1534
1535
1536
1537
1538
1539
1629
1630
1631
1632
1633