digraph G {
id="graph_96203";
subgraph graph_stage_96203 {
id="graph_stage_96203";
isCluster="true";
label="Stage 96203";
subgraph cluster_114274 {
id="cluster_114274";
isCluster="true";
label="Exchange";
43946 [id="node_43946" labelType="html" label="ShuffledRowRDD [43946] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114271 {
id="cluster_114271";
isCluster="true";
label="WholeStageCodegen (1)";
43947 [id="node_43947" labelType="html" label="MapPartitionsRDD [43947] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114294 {
id="cluster_114294";
isCluster="true";
label="Exchange";
43958 [id="node_43958" labelType="html" label="ShuffledRowRDD [43958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114291 {
id="cluster_114291";
isCluster="true";
label="WholeStageCodegen (4)";
43959 [id="node_43959" labelType="html" label="MapPartitionsRDD [43959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114329 {
id="cluster_114329";
isCluster="true";
label="Exchange";
43962 [id="node_43962" labelType="html" label="ShuffledRowRDD [43962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114326 {
id="cluster_114326";
isCluster="true";
label="WholeStageCodegen (6)";
43963 [id="node_43963" labelType="html" label="MapPartitionsRDD [43963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114283 {
id="cluster_114283";
isCluster="true";
label="WholeStageCodegen (7)";
43964 [id="node_43964" labelType="html" label="ZippedPartitionsRDD2 [43964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43965 [id="node_43965" labelType="html" label="MapPartitionsRDD [43965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114282 {
id="cluster_114282";
isCluster="true";
label="InMemoryTableScan";
43966 [id="node_43966" labelType="html" label="MapPartitionsRDD [43966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43967 [id="node_43967" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#882764 AS qty#882766, demandChannel#882759, demandStream#882760, cachedKpis#882765 AS kpis#882767]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#882763L, cachedShardId#882762], 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=1388014]\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=1388010]\n : +- *(2) Has... [43967] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114280 {
id="cluster_114280";
isCluster="true";
label="Exchange";
43974 [id="node_43974" labelType="html" label="ShuffledRowRDD [43974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114277 {
id="cluster_114277";
isCluster="true";
label="WholeStageCodegen (4)";
43975 [id="node_43975" labelType="html" label="MapPartitionsRDD [43975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114263 {
id="cluster_114263";
isCluster="true";
label="WholeStageCodegen (5)";
43976 [id="node_43976" labelType="html" label="ZippedPartitionsRDD2 [43976] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43977 [id="node_43977" labelType="html" label="MapPartitionsRDD [43977] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114344 {
id="cluster_114344";
isCluster="true";
label="InMemoryTableScan";
43978 [id="node_43978" labelType="html" label="MapPartitionsRDD [43978] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43979 [id="node_43979" labelType="html" label="MapPartitionsRDD [43979] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43980 [id="node_43980" labelType="html" label="MapPartitionsRDD [43980] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114341 {
id="cluster_114341";
isCluster="true";
label="WholeStageCodegen (6)";
43981 [id="node_43981" labelType="html" label="MapPartitionsRDD [43981] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114262 {
id="cluster_114262";
isCluster="true";
label="Union";
43982 [id="node_43982" labelType="html" label="UnionRDD [43982] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114261 {
id="cluster_114261";
isCluster="true";
label="InMemoryTableScan";
43983 [id="node_43983" labelType="html" label="MapPartitionsRDD [43983] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43984 [id="node_43984" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#882999, null AS demandStream#883000, [] AS kpis#883034, true AS isNewlyCalculated#883002]\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#882991, ), isnull(shardId#882991), coalesce(worklistShardItemId#882992L, 0), isnull(worklistShardItemId#882992L), coalesce(version#882993, 0), isnull(version#882993), coalesce(product#882994, ), isnull(product#882994), coalesce(plant#882995, ), isnull(plant#882995), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#882766, 0.0))), isnull(qty#... [43984] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43985 [id="node_43985" labelType="html" label="MapPartitionsRDD [43985] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43986 [id="node_43986" labelType="html" label="MapPartitionsRDD [43986] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
43987 [id="node_43987" labelType="html" label="MapPartitionsRDD [43987] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114256 {
id="cluster_114256";
isCluster="true";
label="WholeStageCodegen (15)";
43988 [id="node_43988" labelType="html" label="MapPartitionsRDD [43988] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_114255 {
id="cluster_114255";
isCluster="true";
label="Exchange";
43989 [id="node_43989" labelType="html" label="MapPartitionsRDD [43989] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
43946->43947;
43958->43959;
43962->43963;
43959->43964;
43963->43964;
43964->43965;
43965->43966;
43966->43967;
43974->43975;
43947->43976;
43975->43976;
43976->43977;
43967->43978;
43978->43979;
43979->43980;
43980->43981;
43977->43982;
43981->43982;
43982->43983;
43983->43984;
43984->43985;
43985->43986;
43986->43987;
43987->43988;
43988->43989;
}
43945,43946
43957,43958
43961,43962
43973,43974
43967
43984
43958
43959
43962
43963
43964
43965
43966
43967
43974
43975
43976
43977
43978
43979
43980
43981
43982
43983
43984
43985
43986
43987
43988
43989