digraph G {
id="graph_99300";
subgraph graph_stage_99300 {
id="graph_stage_99300";
isCluster="true";
label="Stage 99300";
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_118793 {
id="cluster_118793";
isCluster="true";
label="Exchange";
45670 [id="node_45670" labelType="html" label="ShuffledRowRDD [45670] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118792 {
id="cluster_118792";
isCluster="true";
label="ObjectHashAggregate";
45671 [id="node_45671" labelType="html" label="MapPartitionsRDD [45671] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118804 {
id="cluster_118804";
isCluster="true";
label="InMemoryTableScan";
45672 [id="node_45672" labelType="html" label="MapPartitionsRDD [45672] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45673 [id="node_45673" labelType="html" label="MapPartitionsRDD [45673] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45674 [id="node_45674" labelType="html" label="MapPartitionsRDD [45674] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118800 {
id="cluster_118800";
isCluster="true";
label="WholeStageCodegen (12)";
45675 [id="node_45675" labelType="html" label="MapPartitionsRDD [45675] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118791 {
id="cluster_118791";
isCluster="true";
label="Union";
45676 [id="node_45676" labelType="html" label="UnionRDD [45676] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118790 {
id="cluster_118790";
isCluster="true";
label="Exchange";
45677 [id="node_45677" labelType="html" label="MapPartitionsRDD [45677] [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;
45670->45671;
45625->45672;
45672->45673;
45673->45674;
45674->45675;
45671->45676;
45675->45676;
45676->45677;
}
45586,45587
45598,45599
45602,45603
45614,45615
45669,45670
45608
45625