digraph G {
id="graph_99310";
subgraph graph_stage_99310 {
id="graph_stage_99310";
isCluster="true";
label="Stage 99310";
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}"];
}
subgraph cluster_118886 {
id="cluster_118886";
isCluster="true";
label="InMemoryTableScan";
45691 [id="node_45691" labelType="html" label="MapPartitionsRDD [45691] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45692 [id="node_45692" labelType="html" label="MapPartitionsRDD [45692] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45693 [id="node_45693" labelType="html" label="MapPartitionsRDD [45693] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118881 {
id="cluster_118881";
isCluster="true";
label="WholeStageCodegen (3)";
45694 [id="node_45694" labelType="html" label="MapPartitionsRDD [45694] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118880 {
id="cluster_118880";
isCluster="true";
label="Exchange";
45695 [id="node_45695" labelType="html" label="MapPartitionsRDD [45695] [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->45691;
45691->45692;
45692->45693;
45693->45694;
45694->45695;
}
45586,45587
45598,45599
45602,45603
45614,45615
45608
45625