digraph G {
id="graph_99299";
subgraph graph_stage_99299 {
id="graph_stage_99299";
isCluster="true";
label="Stage 99299";
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_118799 {
id="cluster_118799";
isCluster="true";
label="InMemoryTableScan";
45664 [id="node_45664" labelType="html" label="MapPartitionsRDD [45664] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45665 [id="node_45665" labelType="html" label="MapPartitionsRDD [45665] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
45666 [id="node_45666" labelType="html" label="MapPartitionsRDD [45666] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118795 {
id="cluster_118795";
isCluster="true";
label="WholeStageCodegen (11)";
45667 [id="node_45667" labelType="html" label="MapPartitionsRDD [45667] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118794 {
id="cluster_118794";
isCluster="true";
label="ObjectHashAggregate";
45668 [id="node_45668" labelType="html" label="MapPartitionsRDD [45668] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_118793 {
id="cluster_118793";
isCluster="true";
label="Exchange";
45669 [id="node_45669" labelType="html" label="MapPartitionsRDD [45669] [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->45664;
45664->45665;
45665->45666;
45666->45667;
45667->45668;
45668->45669;
}
45586,45587
45598,45599
45602,45603
45614,45615
45608
45625