digraph G { id="graph_104833"; subgraph graph_stage_104833 { id="graph_stage_104833"; isCluster="true"; label="Stage 104833"; subgraph cluster_130998 { id="cluster_130998"; isCluster="true"; label="Exchange"; 50247 [id="node_50247" labelType="html" label="ShuffledRowRDD [50247] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130995 { id="cluster_130995"; isCluster="true"; label="WholeStageCodegen (1)"; 50248 [id="node_50248" labelType="html" label="MapPartitionsRDD [50248] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131018 { id="cluster_131018"; isCluster="true"; label="Exchange"; 50259 [id="node_50259" labelType="html" label="ShuffledRowRDD [50259] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131015 { id="cluster_131015"; isCluster="true"; label="WholeStageCodegen (4)"; 50260 [id="node_50260" labelType="html" label="MapPartitionsRDD [50260] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131053 { id="cluster_131053"; isCluster="true"; label="Exchange"; 50263 [id="node_50263" labelType="html" label="ShuffledRowRDD [50263] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131050 { id="cluster_131050"; isCluster="true"; label="WholeStageCodegen (6)"; 50264 [id="node_50264" labelType="html" label="MapPartitionsRDD [50264] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131007 { id="cluster_131007"; isCluster="true"; label="WholeStageCodegen (7)"; 50265 [id="node_50265" labelType="html" label="ZippedPartitionsRDD2 [50265] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50266 [id="node_50266" labelType="html" label="MapPartitionsRDD [50266] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131006 { id="cluster_131006"; isCluster="true"; label="InMemoryTableScan"; 50267 [id="node_50267" labelType="html" label="MapPartitionsRDD [50267] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50268 [id="node_50268" labelType="html" label="*(7) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, cachedQty#1006539 AS qty#1006541, demandChannel#1006534, demandStream#1006535, cachedKpis#1006540 AS kpis#1006542]\n+- *(7) SortMergeJoin [worklistShardItemId#943632L, shardId#943631], [cachedWorklistShardItemId#1006538L, cachedShardId#1006537], 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=1632055]\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=1632051]\n : +- ... [50268] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131004 { id="cluster_131004"; isCluster="true"; label="Exchange"; 50275 [id="node_50275" labelType="html" label="ShuffledRowRDD [50275] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131001 { id="cluster_131001"; isCluster="true"; label="WholeStageCodegen (4)"; 50276 [id="node_50276" labelType="html" label="MapPartitionsRDD [50276] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130987 { id="cluster_130987"; isCluster="true"; label="WholeStageCodegen (5)"; 50277 [id="node_50277" labelType="html" label="ZippedPartitionsRDD2 [50277] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50278 [id="node_50278" labelType="html" label="MapPartitionsRDD [50278] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131068 { id="cluster_131068"; isCluster="true"; label="InMemoryTableScan"; 50279 [id="node_50279" labelType="html" label="MapPartitionsRDD [50279] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50280 [id="node_50280" labelType="html" label="MapPartitionsRDD [50280] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50281 [id="node_50281" labelType="html" label="MapPartitionsRDD [50281] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131065 { id="cluster_131065"; isCluster="true"; label="WholeStageCodegen (6)"; 50282 [id="node_50282" labelType="html" label="MapPartitionsRDD [50282] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130986 { id="cluster_130986"; isCluster="true"; label="Union"; 50283 [id="node_50283" labelType="html" label="UnionRDD [50283] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130985 { id="cluster_130985"; isCluster="true"; label="InMemoryTableScan"; 50284 [id="node_50284" labelType="html" label="MapPartitionsRDD [50284] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50285 [id="node_50285" labelType="html" label="Union\n:- *(5) Project [shardId#943631, worklistShardItemId#943632L, version#943633, product#943634, plant#943635, qty#943638, null AS demandChannel#1006774, null AS demandStream#1006775, [] AS kpis#1006809, true AS isNewlyCalculated#1006777]\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#1006766, ), isnull(shardId#1006766), coalesce(worklistShardItemId#1006767L, 0), isnull(worklistShardItemId#1006767L), coalesce(version#1006768, 0), isnull(version#1006768), coalesce(product#1006769, ), isnull(product#1006769), coalesce(plant#1006770, ), isnull(plant#1006770), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1006541, 0.0)... [50285] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50286 [id="node_50286" labelType="html" label="MapPartitionsRDD [50286] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50287 [id="node_50287" labelType="html" label="MapPartitionsRDD [50287] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50288 [id="node_50288" labelType="html" label="MapPartitionsRDD [50288] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130980 { id="cluster_130980"; isCluster="true"; label="WholeStageCodegen (15)"; 50289 [id="node_50289" labelType="html" label="MapPartitionsRDD [50289] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130979 { id="cluster_130979"; isCluster="true"; label="Exchange"; 50290 [id="node_50290" labelType="html" label="MapPartitionsRDD [50290] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50247->50248; 50259->50260; 50263->50264; 50260->50265; 50264->50265; 50265->50266; 50266->50267; 50267->50268; 50275->50276; 50248->50277; 50276->50277; 50277->50278; 50268->50279; 50279->50280; 50280->50281; 50281->50282; 50278->50283; 50282->50283; 50283->50284; 50284->50285; 50285->50286; 50286->50287; 50287->50288; 50288->50289; 50289->50290; }