digraph G {
id="graph_101338";
subgraph graph_stage_101338 {
id="graph_stage_101338";
isCluster="true";
label="Stage 101338";
subgraph cluster_125370 {
id="cluster_125370";
isCluster="true";
label="Exchange";
47961 [id="node_47961" labelType="html" label="ShuffledRowRDD [47961] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125367 {
id="cluster_125367";
isCluster="true";
label="WholeStageCodegen (1)";
47962 [id="node_47962" labelType="html" label="MapPartitionsRDD [47962] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125390 {
id="cluster_125390";
isCluster="true";
label="Exchange";
47973 [id="node_47973" labelType="html" label="ShuffledRowRDD [47973] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125387 {
id="cluster_125387";
isCluster="true";
label="WholeStageCodegen (4)";
47974 [id="node_47974" labelType="html" label="MapPartitionsRDD [47974] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125428 {
id="cluster_125428";
isCluster="true";
label="Exchange";
47977 [id="node_47977" labelType="html" label="ShuffledRowRDD [47977] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125425 {
id="cluster_125425";
isCluster="true";
label="WholeStageCodegen (6)";
47978 [id="node_47978" labelType="html" label="MapPartitionsRDD [47978] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125379 {
id="cluster_125379";
isCluster="true";
label="WholeStageCodegen (7)";
47979 [id="node_47979" labelType="html" label="ZippedPartitionsRDD2 [47979] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47980 [id="node_47980" labelType="html" label="MapPartitionsRDD [47980] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125378 {
id="cluster_125378";
isCluster="true";
label="InMemoryTableScan";
47981 [id="node_47981" labelType="html" label="MapPartitionsRDD [47981] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47982 [id="node_47982" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#960366 AS qty#960368, demandChannel#960361, demandStream#960362, cachedKpis#960367 AS kpis#960369]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#960365L, cachedShardId#960364], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1595304]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1595300]\n : +- *(2) Has... [47982] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125376 {
id="cluster_125376";
isCluster="true";
label="Exchange";
47989 [id="node_47989" labelType="html" label="ShuffledRowRDD [47989] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125373 {
id="cluster_125373";
isCluster="true";
label="WholeStageCodegen (4)";
47990 [id="node_47990" labelType="html" label="MapPartitionsRDD [47990] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125357 {
id="cluster_125357";
isCluster="true";
label="WholeStageCodegen (5)";
47991 [id="node_47991" labelType="html" label="ZippedPartitionsRDD2 [47991] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47992 [id="node_47992" labelType="html" label="MapPartitionsRDD [47992] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125444 {
id="cluster_125444";
isCluster="true";
label="InMemoryTableScan";
47993 [id="node_47993" labelType="html" label="MapPartitionsRDD [47993] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47994 [id="node_47994" labelType="html" label="MapPartitionsRDD [47994] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47995 [id="node_47995" labelType="html" label="MapPartitionsRDD [47995] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125441 {
id="cluster_125441";
isCluster="true";
label="WholeStageCodegen (6)";
47996 [id="node_47996" labelType="html" label="MapPartitionsRDD [47996] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125356 {
id="cluster_125356";
isCluster="true";
label="Union";
47997 [id="node_47997" labelType="html" label="UnionRDD [47997] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125355 {
id="cluster_125355";
isCluster="true";
label="InMemoryTableScan";
47998 [id="node_47998" labelType="html" label="MapPartitionsRDD [47998] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
47999 [id="node_47999" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#960601, null AS demandStream#960602, [] AS kpis#960636, true AS isNewlyCalculated#960604]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#960593, ), isnull(shardId#960593), coalesce(worklistShardItemId#960594L, 0), isnull(worklistShardItemId#960594L), coalesce(version#960595, 0), isnull(version#960595), coalesce(product#960596, ), isnull(product#960596), coalesce(plant#960597, ), isnull(plant#960597), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#960368, 0.0))), isnull(qty#... [47999] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125816 {
id="cluster_125816";
isCluster="true";
label="Exchange";
48127 [id="node_48127" labelType="html" label="ShuffledRowRDD [48127] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125815 {
id="cluster_125815";
isCluster="true";
label="ObjectHashAggregate";
48128 [id="node_48128" labelType="html" label="MapPartitionsRDD [48128] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125827 {
id="cluster_125827";
isCluster="true";
label="InMemoryTableScan";
48129 [id="node_48129" labelType="html" label="MapPartitionsRDD [48129] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48130 [id="node_48130" labelType="html" label="MapPartitionsRDD [48130] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48131 [id="node_48131" labelType="html" label="MapPartitionsRDD [48131] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125823 {
id="cluster_125823";
isCluster="true";
label="WholeStageCodegen (12)";
48132 [id="node_48132" labelType="html" label="MapPartitionsRDD [48132] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125814 {
id="cluster_125814";
isCluster="true";
label="Union";
48133 [id="node_48133" labelType="html" label="UnionRDD [48133] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_125813 {
id="cluster_125813";
isCluster="true";
label="Exchange";
48134 [id="node_48134" labelType="html" label="MapPartitionsRDD [48134] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
47961->47962;
47973->47974;
47977->47978;
47974->47979;
47978->47979;
47979->47980;
47980->47981;
47981->47982;
47989->47990;
47962->47991;
47990->47991;
47991->47992;
47982->47993;
47993->47994;
47994->47995;
47995->47996;
47992->47997;
47996->47997;
47997->47998;
47998->47999;
48127->48128;
47999->48129;
48129->48130;
48130->48131;
48131->48132;
48128->48133;
48132->48133;
48133->48134;
}
47960,47961
47972,47973
47976,47977
47988,47989
48126,48127
47982
47999