digraph G { id="graph_106161"; subgraph graph_stage_106161 { id="graph_stage_106161"; isCluster="true"; label="Stage 106161"; 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}"]; } subgraph cluster_134458 { id="cluster_134458"; isCluster="true"; label="InMemoryTableScan"; 51462 [id="node_51462" labelType="html" label="MapPartitionsRDD [51462] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51463 [id="node_51463" labelType="html" label="MapPartitionsRDD [51463] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 51464 [id="node_51464" labelType="html" label="MapPartitionsRDD [51464] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134453 { id="cluster_134453"; isCluster="true"; label="WholeStageCodegen (3)"; 51465 [id="node_51465" labelType="html" label="MapPartitionsRDD [51465] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_134452 { id="cluster_134452"; isCluster="true"; label="Exchange"; 51466 [id="node_51466" labelType="html" label="MapPartitionsRDD [51466] [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->51462; 51462->51463; 51463->51464; 51464->51465; 51465->51466; }