digraph G {
id="graph_90329";
subgraph graph_stage_90329 {
id="graph_stage_90329";
isCluster="true";
label="Stage 90329";
subgraph cluster_109236 {
id="cluster_109236";
isCluster="true";
label="Exchange";
41806 [id="node_41806" labelType="html" label="ShuffledRowRDD [41806] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109233 {
id="cluster_109233";
isCluster="true";
label="WholeStageCodegen (1)";
41807 [id="node_41807" labelType="html" label="MapPartitionsRDD [41807] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109256 {
id="cluster_109256";
isCluster="true";
label="Exchange";
41818 [id="node_41818" labelType="html" label="ShuffledRowRDD [41818] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109253 {
id="cluster_109253";
isCluster="true";
label="WholeStageCodegen (4)";
41819 [id="node_41819" labelType="html" label="MapPartitionsRDD [41819] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109285 {
id="cluster_109285";
isCluster="true";
label="Exchange";
41822 [id="node_41822" labelType="html" label="ShuffledRowRDD [41822] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109282 {
id="cluster_109282";
isCluster="true";
label="WholeStageCodegen (6)";
41823 [id="node_41823" labelType="html" label="MapPartitionsRDD [41823] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109245 {
id="cluster_109245";
isCluster="true";
label="WholeStageCodegen (7)";
41824 [id="node_41824" labelType="html" label="ZippedPartitionsRDD2 [41824] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41825 [id="node_41825" labelType="html" label="MapPartitionsRDD [41825] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109244 {
id="cluster_109244";
isCluster="true";
label="InMemoryTableScan";
41826 [id="node_41826" labelType="html" label="MapPartitionsRDD [41826] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41827 [id="node_41827" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#837979 AS qty#837981, demandChannel#837974, demandStream#837975, cachedKpis#837980 AS kpis#837982]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#837978L, cachedShardId#837977], Inner\n :- *(4) Sort [worklistShardItemId#815741L ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#815741L, shardId#815740, 37), ENSURE_REQUIREMENTS, [plan_id=1375257]\n : +- *(3) HashAggregate(keys=[plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743], functions=[], output=[shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744])\n : +- Exchange hashpartitioning(plant#815744, shardId#815740, version#815742, worklistShardItemId#815741L, product#815743, 37), ENSURE_REQUIREMENTS, [plan_id=1375253]\n : +- *(2) Has... [41827] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109242 {
id="cluster_109242";
isCluster="true";
label="Exchange";
41834 [id="node_41834" labelType="html" label="ShuffledRowRDD [41834] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109239 {
id="cluster_109239";
isCluster="true";
label="WholeStageCodegen (4)";
41835 [id="node_41835" labelType="html" label="MapPartitionsRDD [41835] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109225 {
id="cluster_109225";
isCluster="true";
label="WholeStageCodegen (5)";
41836 [id="node_41836" labelType="html" label="ZippedPartitionsRDD2 [41836] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41837 [id="node_41837" labelType="html" label="MapPartitionsRDD [41837] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109306 {
id="cluster_109306";
isCluster="true";
label="InMemoryTableScan";
41838 [id="node_41838" labelType="html" label="MapPartitionsRDD [41838] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41839 [id="node_41839" labelType="html" label="MapPartitionsRDD [41839] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41840 [id="node_41840" labelType="html" label="MapPartitionsRDD [41840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109303 {
id="cluster_109303";
isCluster="true";
label="WholeStageCodegen (6)";
41841 [id="node_41841" labelType="html" label="MapPartitionsRDD [41841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109224 {
id="cluster_109224";
isCluster="true";
label="Union";
41842 [id="node_41842" labelType="html" label="UnionRDD [41842] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109223 {
id="cluster_109223";
isCluster="true";
label="InMemoryTableScan";
41843 [id="node_41843" labelType="html" label="MapPartitionsRDD [41843] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41844 [id="node_41844" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#838214, null AS demandStream#838215, [] AS kpis#838249, true AS isNewlyCalculated#838217]\n: +- *(5) SortMergeJoin [coalesce(shardId#815740, ), isnull(shardId#815740), coalesce(worklistShardItemId#815741L, 0), isnull(worklistShardItemId#815741L), coalesce(version#815742, 0), isnull(version#815742), coalesce(product#815743, ), isnull(product#815743), coalesce(plant#815744, ), isnull(plant#815744), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#815747, 0.0))), isnull(qty#815747)], [coalesce(shardId#838206, ), isnull(shardId#838206), coalesce(worklistShardItemId#838207L, 0), isnull(worklistShardItemId#838207L), coalesce(version#838208, 0), isnull(version#838208), coalesce(product#838209, ), isnull(product#838209), coalesce(plant#838210, ), isnull(plant#838210), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#837981, 0.0))), isnull(qty#... [41844] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109440 {
id="cluster_109440";
isCluster="true";
label="InMemoryTableScan";
41883 [id="node_41883" labelType="html" label="MapPartitionsRDD [41883] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41884 [id="node_41884" labelType="html" label="MapPartitionsRDD [41884] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
41885 [id="node_41885" labelType="html" label="MapPartitionsRDD [41885] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109436 {
id="cluster_109436";
isCluster="true";
label="WholeStageCodegen (11)";
41886 [id="node_41886" labelType="html" label="MapPartitionsRDD [41886] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109435 {
id="cluster_109435";
isCluster="true";
label="ObjectHashAggregate";
41887 [id="node_41887" labelType="html" label="MapPartitionsRDD [41887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_109434 {
id="cluster_109434";
isCluster="true";
label="Exchange";
41888 [id="node_41888" labelType="html" label="MapPartitionsRDD [41888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
41806->41807;
41818->41819;
41822->41823;
41819->41824;
41823->41824;
41824->41825;
41825->41826;
41826->41827;
41834->41835;
41807->41836;
41835->41836;
41836->41837;
41827->41838;
41838->41839;
41839->41840;
41840->41841;
41837->41842;
41841->41842;
41842->41843;
41843->41844;
41844->41883;
41883->41884;
41884->41885;
41885->41886;
41886->41887;
41887->41888;
}
41805,41806
41817,41818
41821,41822
41833,41834
41827
41844
41818
41819
41822
41823
41824
41825
41826
41827
41834
41835
41836
41837
41838
41839
41840
41841
41842
41843
41844
41883
41884
41885
41886
41887
41888