digraph G { id="graph_95227"; subgraph graph_stage_95227 { id="graph_stage_95227"; isCluster="true"; label="Stage 95227"; subgraph cluster_112341 { id="cluster_112341"; isCluster="true"; label="Exchange"; 43126 [id="node_43126" labelType="html" label="ShuffledRowRDD [43126] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112338 { id="cluster_112338"; isCluster="true"; label="WholeStageCodegen (1)"; 43127 [id="node_43127" labelType="html" label="MapPartitionsRDD [43127] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112361 { id="cluster_112361"; isCluster="true"; label="Exchange"; 43138 [id="node_43138" labelType="html" label="ShuffledRowRDD [43138] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112358 { id="cluster_112358"; isCluster="true"; label="WholeStageCodegen (4)"; 43139 [id="node_43139" labelType="html" label="MapPartitionsRDD [43139] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112396 { id="cluster_112396"; isCluster="true"; label="Exchange"; 43142 [id="node_43142" labelType="html" label="ShuffledRowRDD [43142] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112393 { id="cluster_112393"; isCluster="true"; label="WholeStageCodegen (6)"; 43143 [id="node_43143" labelType="html" label="MapPartitionsRDD [43143] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112350 { id="cluster_112350"; isCluster="true"; label="WholeStageCodegen (7)"; 43144 [id="node_43144" labelType="html" label="ZippedPartitionsRDD2 [43144] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43145 [id="node_43145" labelType="html" label="MapPartitionsRDD [43145] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112349 { id="cluster_112349"; isCluster="true"; label="InMemoryTableScan"; 43146 [id="node_43146" labelType="html" label="MapPartitionsRDD [43146] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43147 [id="node_43147" labelType="html" label="*(7) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, cachedQty#865769 AS qty#865771, demandChannel#865764, demandStream#865765, cachedKpis#865770 AS kpis#865772]\n+- *(7) SortMergeJoin [worklistShardItemId#815741L, shardId#815740], [cachedWorklistShardItemId#865768L, cachedShardId#865767], 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=1383136]\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=1383132]\n : +- *(2) Has... [43147] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112347 { id="cluster_112347"; isCluster="true"; label="Exchange"; 43154 [id="node_43154" labelType="html" label="ShuffledRowRDD [43154] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112344 { id="cluster_112344"; isCluster="true"; label="WholeStageCodegen (4)"; 43155 [id="node_43155" labelType="html" label="MapPartitionsRDD [43155] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112330 { id="cluster_112330"; isCluster="true"; label="WholeStageCodegen (5)"; 43156 [id="node_43156" labelType="html" label="ZippedPartitionsRDD2 [43156] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43157 [id="node_43157" labelType="html" label="MapPartitionsRDD [43157] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112411 { id="cluster_112411"; isCluster="true"; label="InMemoryTableScan"; 43158 [id="node_43158" labelType="html" label="MapPartitionsRDD [43158] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43159 [id="node_43159" labelType="html" label="MapPartitionsRDD [43159] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43160 [id="node_43160" labelType="html" label="MapPartitionsRDD [43160] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112408 { id="cluster_112408"; isCluster="true"; label="WholeStageCodegen (6)"; 43161 [id="node_43161" labelType="html" label="MapPartitionsRDD [43161] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112329 { id="cluster_112329"; isCluster="true"; label="Union"; 43162 [id="node_43162" labelType="html" label="UnionRDD [43162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112328 { id="cluster_112328"; isCluster="true"; label="InMemoryTableScan"; 43163 [id="node_43163" labelType="html" label="MapPartitionsRDD [43163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43164 [id="node_43164" labelType="html" label="Union\n:- *(5) Project [shardId#815740, worklistShardItemId#815741L, version#815742, product#815743, plant#815744, qty#815747, null AS demandChannel#866004, null AS demandStream#866005, [] AS kpis#866039, true AS isNewlyCalculated#866007]\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#865996, ), isnull(shardId#865996), coalesce(worklistShardItemId#865997L, 0), isnull(worklistShardItemId#865997L), coalesce(version#865998, 0), isnull(version#865998), coalesce(product#865999, ), isnull(product#865999), coalesce(plant#866000, ), isnull(plant#866000), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#865771, 0.0))), isnull(qty#... [43164] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112761 { id="cluster_112761"; isCluster="true"; label="InMemoryTableScan"; 43294 [id="node_43294" labelType="html" label="MapPartitionsRDD [43294] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43295 [id="node_43295" labelType="html" label="MapPartitionsRDD [43295] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43296 [id="node_43296" labelType="html" label="MapPartitionsRDD [43296] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112757 { id="cluster_112757"; isCluster="true"; label="WholeStageCodegen (3)"; 43297 [id="node_43297" labelType="html" label="MapPartitionsRDD [43297] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112756 { id="cluster_112756"; isCluster="true"; label="Exchange"; 43298 [id="node_43298" labelType="html" label="MapPartitionsRDD [43298] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43126->43127; 43138->43139; 43142->43143; 43139->43144; 43143->43144; 43144->43145; 43145->43146; 43146->43147; 43154->43155; 43127->43156; 43155->43156; 43156->43157; 43147->43158; 43158->43159; 43159->43160; 43160->43161; 43157->43162; 43161->43162; 43162->43163; 43163->43164; 43164->43294; 43294->43295; 43295->43296; 43296->43297; 43297->43298; }