digraph G {
id="graph_102368";
subgraph graph_stage_102368 {
id="graph_stage_102368";
isCluster="true";
label="Stage 102368";
subgraph cluster_127893 {
id="cluster_127893";
isCluster="true";
label="Exchange";
48927 [id="node_48927" labelType="html" label="ShuffledRowRDD [48927] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127890 {
id="cluster_127890";
isCluster="true";
label="WholeStageCodegen (1)";
48928 [id="node_48928" labelType="html" label="MapPartitionsRDD [48928] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127913 {
id="cluster_127913";
isCluster="true";
label="Exchange";
48939 [id="node_48939" labelType="html" label="ShuffledRowRDD [48939] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127910 {
id="cluster_127910";
isCluster="true";
label="WholeStageCodegen (4)";
48940 [id="node_48940" labelType="html" label="MapPartitionsRDD [48940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127948 {
id="cluster_127948";
isCluster="true";
label="Exchange";
48943 [id="node_48943" labelType="html" label="ShuffledRowRDD [48943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127945 {
id="cluster_127945";
isCluster="true";
label="WholeStageCodegen (6)";
48944 [id="node_48944" labelType="html" label="MapPartitionsRDD [48944] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127902 {
id="cluster_127902";
isCluster="true";
label="WholeStageCodegen (7)";
48945 [id="node_48945" labelType="html" label="ZippedPartitionsRDD2 [48945] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48946 [id="node_48946" labelType="html" label="MapPartitionsRDD [48946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127901 {
id="cluster_127901";
isCluster="true";
label="InMemoryTableScan";
48947 [id="node_48947" labelType="html" label="MapPartitionsRDD [48947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48948 [id="node_48948" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#978749 AS qty#978751, demandChannel#978744, demandStream#978745, cachedKpis#978750 AS kpis#978752]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#978748L, cachedShardId#978747], Inner\n :- *(4) Sort [worklistShardItemId#943632L ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#943632L, shardId#943631, 37), ENSURE_REQUIREMENTS, [plan_id=1624120]\n : +- *(3) HashAggregate(keys=[plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634], functions=[], output=[shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635])\n : +- Exchange hashpartitioning(plant#943635, shardId#943631, version#943633, worklistShardItemId#943632L, product#943634, 37), ENSURE_REQUIREMENTS, [plan_id=1624116]\n : +- *(2) Has... [48948] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127899 {
id="cluster_127899";
isCluster="true";
label="Exchange";
48955 [id="node_48955" labelType="html" label="ShuffledRowRDD [48955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127896 {
id="cluster_127896";
isCluster="true";
label="WholeStageCodegen (4)";
48956 [id="node_48956" labelType="html" label="MapPartitionsRDD [48956] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127882 {
id="cluster_127882";
isCluster="true";
label="WholeStageCodegen (5)";
48957 [id="node_48957" labelType="html" label="ZippedPartitionsRDD2 [48957] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48958 [id="node_48958" labelType="html" label="MapPartitionsRDD [48958] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127963 {
id="cluster_127963";
isCluster="true";
label="InMemoryTableScan";
48959 [id="node_48959" labelType="html" label="MapPartitionsRDD [48959] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48960 [id="node_48960" labelType="html" label="MapPartitionsRDD [48960] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48961 [id="node_48961" labelType="html" label="MapPartitionsRDD [48961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127960 {
id="cluster_127960";
isCluster="true";
label="WholeStageCodegen (6)";
48962 [id="node_48962" labelType="html" label="MapPartitionsRDD [48962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127881 {
id="cluster_127881";
isCluster="true";
label="Union";
48963 [id="node_48963" labelType="html" label="UnionRDD [48963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_127880 {
id="cluster_127880";
isCluster="true";
label="InMemoryTableScan";
48964 [id="node_48964" labelType="html" label="MapPartitionsRDD [48964] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
48965 [id="node_48965" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#978984, null AS demandStream#978985, [] AS kpis#979019, true AS isNewlyCalculated#978987]\n: +- *(5) SortMergeJoin [coalesce(shardId#943631, ), isnull(shardId#943631), coalesce(worklistShardItemId#943632L, 0), isnull(worklistShardItemId#943632L), coalesce(version#943633, 0), isnull(version#943633), coalesce(product#943634, ), isnull(product#943634), coalesce(plant#943635, ), isnull(plant#943635), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#943638, 0.0))), isnull(qty#943638)], [coalesce(shardId#978976, ), isnull(shardId#978976), coalesce(worklistShardItemId#978977L, 0), isnull(worklistShardItemId#978977L), coalesce(version#978978, 0), isnull(version#978978), coalesce(product#978979, ), isnull(product#978979), coalesce(plant#978980, ), isnull(plant#978980), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#978751, 0.0))), isnull(qty#... [48965] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128097 {
id="cluster_128097";
isCluster="true";
label="InMemoryTableScan";
49004 [id="node_49004" labelType="html" label="MapPartitionsRDD [49004] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49005 [id="node_49005" labelType="html" label="MapPartitionsRDD [49005] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49006 [id="node_49006" labelType="html" label="MapPartitionsRDD [49006] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128093 {
id="cluster_128093";
isCluster="true";
label="WholeStageCodegen (11)";
49007 [id="node_49007" labelType="html" label="MapPartitionsRDD [49007] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128092 {
id="cluster_128092";
isCluster="true";
label="ObjectHashAggregate";
49008 [id="node_49008" labelType="html" label="MapPartitionsRDD [49008] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128091 {
id="cluster_128091";
isCluster="true";
label="Exchange";
49009 [id="node_49009" labelType="html" label="MapPartitionsRDD [49009] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
}
48927->48928;
48939->48940;
48943->48944;
48940->48945;
48944->48945;
48945->48946;
48946->48947;
48947->48948;
48955->48956;
48928->48957;
48956->48957;
48957->48958;
48948->48959;
48959->48960;
48960->48961;
48961->48962;
48958->48963;
48962->48963;
48963->48964;
48964->48965;
48965->49004;
49004->49005;
49005->49006;
49006->49007;
49007->49008;
49008->49009;
}
48926,48927
48938,48939
48942,48943
48954,48955
48948
48965
48939
48940
48943
48944
48945
48946
48947
48948
48955
48956
48957
48958
48959
48960
48961
48962
48963
48964
48965
49004
49005
49006
49007
49008
49009