digraph G {
id="graph_101402";
subgraph graph_stage_101402 {
id="graph_stage_101402";
isCluster="true";
label="Stage 101402";
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_126269 {
id="cluster_126269";
isCluster="true";
label="InMemoryTableScan";
48223 [id="node_48223" labelType="html" label="MapPartitionsRDD [48223] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48224 [id="node_48224" labelType="html" label="MapPartitionsRDD [48224] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48225 [id="node_48225" labelType="html" label="MapPartitionsRDD [48225] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126264 {
id="cluster_126264";
isCluster="true";
label="WholeStageCodegen (3)";
48226 [id="node_48226" labelType="html" label="MapPartitionsRDD [48226] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126263 {
id="cluster_126263";
isCluster="true";
label="Exchange";
48227 [id="node_48227" labelType="html" label="MapPartitionsRDD [48227] [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;
47999->48223;
48223->48224;
48224->48225;
48225->48226;
48226->48227;
}
47960,47961
47972,47973
47976,47977
47988,47989
47982
47999