digraph G { id="graph_106099"; subgraph graph_stage_106099 { id="graph_stage_106099"; isCluster="true"; label="Stage 106099"; subgraph cluster_134167 { id="cluster_134167"; isCluster="true"; label="Exchange"; 51358 [id="node_51358" labelType="html" label="ShuffledRowRDD [51358] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134164 { id="cluster_134164"; isCluster="true"; label="WholeStageCodegen (1)"; 51359 [id="node_51359" labelType="html" label="MapPartitionsRDD [51359] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134187 { id="cluster_134187"; isCluster="true"; label="Exchange"; 51370 [id="node_51370" labelType="html" label="ShuffledRowRDD [51370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134184 { id="cluster_134184"; isCluster="true"; label="WholeStageCodegen (4)"; 51371 [id="node_51371" labelType="html" label="MapPartitionsRDD [51371] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134216 { id="cluster_134216"; isCluster="true"; label="Exchange"; 51374 [id="node_51374" labelType="html" label="ShuffledRowRDD [51374] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134213 { id="cluster_134213"; isCluster="true"; label="WholeStageCodegen (6)"; 51375 [id="node_51375" labelType="html" label="MapPartitionsRDD [51375] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134176 { id="cluster_134176"; isCluster="true"; label="WholeStageCodegen (7)"; 51376 [id="node_51376" labelType="html" label="ZippedPartitionsRDD2 [51376] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51377 [id="node_51377" labelType="html" label="MapPartitionsRDD [51377] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134175 { id="cluster_134175"; isCluster="true"; label="InMemoryTableScan"; 51378 [id="node_51378" labelType="html" label="MapPartitionsRDD [51378] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51379 [id="node_51379" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1028186 AS qty#1028188, demandChannel#1028181, demandStream#1028182, cachedKpis#1028187 AS kpis#1028189]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1028185L, cachedShardId#1028184], Inner\n :- *(4) Sort [worklistShardItemId#1011816L ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(worklistShardItemId#1011816L, shardId#1011815, 37), ENSURE_REQUIREMENTS, [plan_id=1678424]\n : +- *(3) HashAggregate(keys=[plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818], functions=[], output=[shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819])\n : +- Exchange hashpartitioning(plant#1011819, shardId#1011815, version#1011817, worklistShardItemId#1011816L, product#1011818, 37), ENSURE_REQUIREMENTS, [plan_id=1... [51379] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134173 { id="cluster_134173"; isCluster="true"; label="Exchange"; 51386 [id="node_51386" labelType="html" label="ShuffledRowRDD [51386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134170 { id="cluster_134170"; isCluster="true"; label="WholeStageCodegen (4)"; 51387 [id="node_51387" labelType="html" label="MapPartitionsRDD [51387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134156 { id="cluster_134156"; isCluster="true"; label="WholeStageCodegen (5)"; 51388 [id="node_51388" labelType="html" label="ZippedPartitionsRDD2 [51388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51389 [id="node_51389" labelType="html" label="MapPartitionsRDD [51389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134237 { id="cluster_134237"; isCluster="true"; label="InMemoryTableScan"; 51390 [id="node_51390" labelType="html" label="MapPartitionsRDD [51390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51391 [id="node_51391" labelType="html" label="MapPartitionsRDD [51391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51392 [id="node_51392" labelType="html" label="MapPartitionsRDD [51392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134234 { id="cluster_134234"; isCluster="true"; label="WholeStageCodegen (6)"; 51393 [id="node_51393" labelType="html" label="MapPartitionsRDD [51393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134155 { id="cluster_134155"; isCluster="true"; label="Union"; 51394 [id="node_51394" labelType="html" label="UnionRDD [51394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134154 { id="cluster_134154"; isCluster="true"; label="InMemoryTableScan"; 51395 [id="node_51395" labelType="html" label="MapPartitionsRDD [51395] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51396 [id="node_51396" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1028421, null AS demandStream#1028422, [] AS kpis#1028456, true AS isNewlyCalculated#1028424]\n: +- *(5) SortMergeJoin [coalesce(shardId#1011815, ), isnull(shardId#1011815), coalesce(worklistShardItemId#1011816L, 0), isnull(worklistShardItemId#1011816L), coalesce(version#1011817, 0), isnull(version#1011817), coalesce(product#1011818, ), isnull(product#1011818), coalesce(plant#1011819, ), isnull(plant#1011819), knownfloatingpointnormalized(normalizenanandzero(coalesce(qty#1011822, 0.0))), isnull(qty#1011822)], [coalesce(shardId#1028413, ), isnull(shardId#1028413), coalesce(worklistShardItemId#1028414L, 0), isnull(worklistShardItemId#1028414L), coalesce(version#1028415, 0), isnull(version#1028415), coalesce(product#1028416, ), isnull(product#1028416), coalesce(plant#1028417, ), isnull(plant#1028417), knownfloatingpointnormalized(normalizenanandzero(coalesce... [51396] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51397 [id="node_51397" labelType="html" label="MapPartitionsRDD [51397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51398 [id="node_51398" labelType="html" label="MapPartitionsRDD [51398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51399 [id="node_51399" labelType="html" label="MapPartitionsRDD [51399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134149 { id="cluster_134149"; isCluster="true"; label="WholeStageCodegen (15)"; 51400 [id="node_51400" labelType="html" label="MapPartitionsRDD [51400] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134148 { id="cluster_134148"; isCluster="true"; label="Exchange"; 51401 [id="node_51401" labelType="html" label="MapPartitionsRDD [51401] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51358->51359; 51370->51371; 51374->51375; 51371->51376; 51375->51376; 51376->51377; 51377->51378; 51378->51379; 51386->51387; 51359->51388; 51387->51388; 51388->51389; 51379->51390; 51390->51391; 51391->51392; 51392->51393; 51389->51394; 51393->51394; 51394->51395; 51395->51396; 51396->51397; 51397->51398; 51398->51399; 51399->51400; 51400->51401; }