digraph G {
id="graph_101516";
subgraph graph_stage_101516 {
id="graph_stage_101516";
isCluster="true";
label="Stage 101516";
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_126254 {
id="cluster_126254";
isCluster="true";
label="Exchange";
48264 [id="node_48264" labelType="html" label="ShuffledRowRDD [48264] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126249 {
id="cluster_126249";
isCluster="true";
label="WholeStageCodegen (6)";
48265 [id="node_48265" labelType="html" label="MapPartitionsRDD [48265] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126248 {
id="cluster_126248";
isCluster="true";
label="SortAggregate";
48266 [id="node_48266" labelType="html" label="MapPartitionsRDD [48266] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126247 {
id="cluster_126247";
isCluster="true";
label="InMemoryTableScan";
48267 [id="node_48267" labelType="html" label="MapPartitionsRDD [48267] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48268 [id="node_48268" labelType="html" label="SortAggregate(key=[demandChannel#964830, shardId#943631, qty#964850, worklistShardItemId#943632L, demandStream#964831], functions=[first(kpis#964859, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#964850, demandChannel#964830, demandStream#964831, kpis#964992])\n+- *(6) Sort [demandChannel#964830 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#964850 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#964831 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#964830, shardId#943631, qty#964850, worklistShardItemId#943632L, demandStream#964831, 37), ENSURE_REQUIREMENTS, [plan_id=1620191]\n +- SortAggregate(key=[demandChannel#964830, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#964850)) AS qty#964850, worklistShardItemId#943632L, demandStream#964831], functions=[partial_first(kpis#964859, false)], output=[demandChannel#964830, shardId#943631, qty#964850, worklistShardItemId#943632L, demandStream#964831, first#96506... [48268] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126464 {
id="cluster_126464";
isCluster="true";
label="InMemoryTableScan";
48309 [id="node_48309" labelType="html" label="MapPartitionsRDD [48309] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48310 [id="node_48310" labelType="html" label="MapPartitionsRDD [48310] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48311 [id="node_48311" labelType="html" label="MapPartitionsRDD [48311] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126460 {
id="cluster_126460";
isCluster="true";
label="WholeStageCodegen (1)";
48312 [id="node_48312" labelType="html" label="MapPartitionsRDD [48312] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126468 {
id="cluster_126468";
isCluster="true";
label="InMemoryTableScan";
48313 [id="node_48313" labelType="html" label="MapPartitionsRDD [48313] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48314 [id="node_48314" labelType="html" label="MapPartitionsRDD [48314] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48315 [id="node_48315" labelType="html" label="MapPartitionsRDD [48315] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126465 {
id="cluster_126465";
isCluster="true";
label="WholeStageCodegen (2)";
48316 [id="node_48316" labelType="html" label="MapPartitionsRDD [48316] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126459 {
id="cluster_126459";
isCluster="true";
label="Union";
48317 [id="node_48317" labelType="html" label="UnionRDD [48317] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126435 {
id="cluster_126435";
isCluster="true";
label="WholeStageCodegen (5)";
48318 [id="node_48318" labelType="html" label="MapPartitionsRDD [48318] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126434 {
id="cluster_126434";
isCluster="true";
label="InMemoryTableScan";
48319 [id="node_48319" labelType="html" label="MapPartitionsRDD [48319] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48320 [id="node_48320" labelType="html" label="*(5) Project [shardId#943631, worklistShardItemId#943632L, version#965679, qty#943638, demandChannel#960601, demandStream#960602, kpis#960636]\n+- *(5) BroadcastHashJoin [shardId#943631, worklistShardItemId#943632L], [shardId#965776, worklistShardItemId#965777L], Inner, BuildRight, false\n :- Union\n : :- *(1) Project [shardId#943631, worklistShardItemId#943632L, qty#943638, demandChannel#960601, demandStream#960602, kpis#960636]\n : : +- *(1) Filter ((NOT isNewlyCalculated#960604 AND isnotnull(shardId#943631)) AND isnotnull(worklistShardItemId#943632L))\n : : +- InMemoryTableScan [demandChannel#960601, demandStream#960602, isNewlyCalculated#960604, kpis#960636, qty#943638, shardId#943631, worklistShardItemId#943632L], [NOT isNewlyCalculated#960604, isnotnull(shardId#943631), isnotnull(worklistShardItemId#943632L)]\n : : +- InMemoryRelation [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, demandChannel#960601, demandStream#960602... [48320] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_126493 {
id="cluster_126493";
isCluster="true";
label="InMemoryTableScan";
48329 [id="node_48329" labelType="html" label="MapPartitionsRDD [48329] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48330 [id="node_48330" labelType="html" label="MapPartitionsRDD [48330] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
48331 [id="node_48331" labelType="html" label="MapPartitionsRDD [48331] [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;
48264->48265;
48265->48266;
48266->48267;
48267->48268;
47999->48309;
48309->48310;
48310->48311;
48311->48312;
48268->48313;
48313->48314;
48314->48315;
48315->48316;
48312->48317;
48316->48317;
48317->48318;
48318->48319;
48319->48320;
48320->48329;
48329->48330;
48330->48331;
}
47960,47961
47972,47973
47976,47977
47988,47989
48263,48264
47982
47999
48268
48320