digraph G {
id="graph_102369";
subgraph graph_stage_102369 {
id="graph_stage_102369";
isCluster="true";
label="Stage 102369";
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_128091 {
id="cluster_128091";
isCluster="true";
label="Exchange";
49010 [id="node_49010" labelType="html" label="ShuffledRowRDD [49010] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128090 {
id="cluster_128090";
isCluster="true";
label="ObjectHashAggregate";
49011 [id="node_49011" labelType="html" label="MapPartitionsRDD [49011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128102 {
id="cluster_128102";
isCluster="true";
label="InMemoryTableScan";
49012 [id="node_49012" labelType="html" label="MapPartitionsRDD [49012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49013 [id="node_49013" labelType="html" label="MapPartitionsRDD [49013] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
49014 [id="node_49014" labelType="html" label="MapPartitionsRDD [49014] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128098 {
id="cluster_128098";
isCluster="true";
label="WholeStageCodegen (12)";
49015 [id="node_49015" labelType="html" label="MapPartitionsRDD [49015] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128089 {
id="cluster_128089";
isCluster="true";
label="Union";
49016 [id="node_49016" labelType="html" label="UnionRDD [49016] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"];
}
subgraph cluster_128088 {
id="cluster_128088";
isCluster="true";
label="Exchange";
49017 [id="node_49017" labelType="html" label="MapPartitionsRDD [49017] [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;
49010->49011;
48965->49012;
49012->49013;
49013->49014;
49014->49015;
49011->49016;
49015->49016;
49016->49017;
}
48926,48927
48938,48939
48942,48943
48954,48955
49009,49010
48948
48965
48939
48940
48943
48944
48945
48946
48947
48948
48955
48956
48957
48958
48959
48960
48961
48962
48963
48964
48965
49010
49011
49012
49013
49014
49015
49016
49017