digraph G {
id="graph_99284";
subgraph graph_stage_99284 {
id="graph_stage_99284";
isCluster="true";
label="Stage 99284";
subgraph cluster_118592 {
id="cluster_118592";
isCluster="true";
label="Exchange";
45587 [id="node_45587" labelType="html" label="ShuffledRowRDD [45587] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118589 {
id="cluster_118589";
isCluster="true";
label="WholeStageCodegen (1)";
45588 [id="node_45588" labelType="html" label="MapPartitionsRDD [45588] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118612 {
id="cluster_118612";
isCluster="true";
label="Exchange";
45599 [id="node_45599" labelType="html" label="ShuffledRowRDD [45599] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118609 {
id="cluster_118609";
isCluster="true";
label="WholeStageCodegen (4)";
45600 [id="node_45600" labelType="html" label="MapPartitionsRDD [45600] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118647 {
id="cluster_118647";
isCluster="true";
label="Exchange";
45603 [id="node_45603" labelType="html" label="ShuffledRowRDD [45603] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118644 {
id="cluster_118644";
isCluster="true";
label="WholeStageCodegen (6)";
45604 [id="node_45604" labelType="html" label="MapPartitionsRDD [45604] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118601 {
id="cluster_118601";
isCluster="true";
label="WholeStageCodegen (7)";
45605 [id="node_45605" labelType="html" label="ZippedPartitionsRDD2 [45605] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45606 [id="node_45606" labelType="html" label="MapPartitionsRDD [45606] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118600 {
id="cluster_118600";
isCluster="true";
label="InMemoryTableScan";
45607 [id="node_45607" labelType="html" label="MapPartitionsRDD [45607] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45608 [id="node_45608" labelType="html" label="*(7) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, cachedQty#915955 AS qty#915957, demandChannel#915950, demandStream#915951, cachedKpis#915956 AS kpis#915958]\n+- *(7) SortMergeJoin [worklistShardItemId#904715L, shardId#904714], [cachedWorklistShardItemId#915954L, cachedShardId#915953], Inner\n :- *(4) Sort [worklistShardItemId#904715L ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#904715L, shardId#904714, 37), ENSURE_REQUIREMENTS, [plan_id=1447676]\n : +- *(3) HashAggregate(keys=[plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717], functions=[], output=[shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718])\n : +- Exchange hashpartitioning(plant#904718, shardId#904714, version#904716, worklistShardItemId#904715L, product#904717, 37), ENSURE_REQUIREMENTS, [plan_id=1447672]\n : +- *(2) Has... [45608] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118598 {
id="cluster_118598";
isCluster="true";
label="Exchange";
45615 [id="node_45615" labelType="html" label="ShuffledRowRDD [45615] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118595 {
id="cluster_118595";
isCluster="true";
label="WholeStageCodegen (4)";
45616 [id="node_45616" labelType="html" label="MapPartitionsRDD [45616] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118581 {
id="cluster_118581";
isCluster="true";
label="WholeStageCodegen (5)";
45617 [id="node_45617" labelType="html" label="ZippedPartitionsRDD2 [45617] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45618 [id="node_45618" labelType="html" label="MapPartitionsRDD [45618] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118663 {
id="cluster_118663";
isCluster="true";
label="InMemoryTableScan";
45619 [id="node_45619" labelType="html" label="MapPartitionsRDD [45619] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45620 [id="node_45620" labelType="html" label="MapPartitionsRDD [45620] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45621 [id="node_45621" labelType="html" label="MapPartitionsRDD [45621] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118660 {
id="cluster_118660";
isCluster="true";
label="WholeStageCodegen (6)";
45622 [id="node_45622" labelType="html" label="MapPartitionsRDD [45622] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118580 {
id="cluster_118580";
isCluster="true";
label="Union";
45623 [id="node_45623" labelType="html" label="UnionRDD [45623] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118579 {
id="cluster_118579";
isCluster="true";
label="InMemoryTableScan";
45624 [id="node_45624" labelType="html" label="MapPartitionsRDD [45624] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45625 [id="node_45625" labelType="html" label="Union\n:- *(5) Project [shardId#904714, worklistShardItemId#904715L, version#904716, product#904717, plant#904718, qty#904721, null AS demandChannel#916190, null AS demandStream#916191, [] AS kpis#916225, true AS isNewlyCalculated#916193]\n: +- *(5) SortMergeJoin [coalesce(shardId#904714, ), isnull(shardId#904714), coalesce(worklistShardItemId#904715L, 0), isnull(worklistShardItemId#904715L), coalesce(version#904716, 0), isnull(version#904716), coalesce(product#904717, ), isnull(product#904717), coalesce(plant#904718, ), isnull(plant#904718), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#904721, 0.0))), isnull(qty#904721)], [coalesce(shardId#916182, ), isnull(shardId#916182), coalesce(worklistShardItemId#916183L, 0), isnull(worklistShardItemId#916183L), coalesce(version#916184, 0), isnull(version#916184), coalesce(product#916185, ), isnull(product#916185), coalesce(plant#916186, ), isnull(plant#916186), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#915957, 0.0))), isnull(qty#... [45625] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45626 [id="node_45626" labelType="html" label="MapPartitionsRDD [45626] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45627 [id="node_45627" labelType="html" label="MapPartitionsRDD [45627] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45628 [id="node_45628" labelType="html" label="MapPartitionsRDD [45628] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118574 {
id="cluster_118574";
isCluster="true";
label="WholeStageCodegen (15)";
45629 [id="node_45629" labelType="html" label="MapPartitionsRDD [45629] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118573 {
id="cluster_118573";
isCluster="true";
label="Exchange";
45630 [id="node_45630" labelType="html" label="MapPartitionsRDD [45630] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
45587->45588;
45599->45600;
45603->45604;
45600->45605;
45604->45605;
45605->45606;
45606->45607;
45607->45608;
45615->45616;
45588->45617;
45616->45617;
45617->45618;
45608->45619;
45619->45620;
45620->45621;
45621->45622;
45618->45623;
45622->45623;
45623->45624;
45624->45625;
45625->45626;
45626->45627;
45627->45628;
45628->45629;
45629->45630;
}
45586,45587
45598,45599
45602,45603
45614,45615
45608
45625