digraph G { id="graph_114530"; subgraph graph_stage_114530 { id="graph_stage_114530"; isCluster="true"; label="Stage 114530"; subgraph cluster_141678 { id="cluster_141678"; isCluster="true"; label="Exchange"; 54550 [id="node_54550" labelType="html" label="ShuffledRowRDD [54550] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141675 { id="cluster_141675"; isCluster="true"; label="WholeStageCodegen (1)"; 54551 [id="node_54551" labelType="html" label="MapPartitionsRDD [54551] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141698 { id="cluster_141698"; isCluster="true"; label="Exchange"; 54562 [id="node_54562" labelType="html" label="ShuffledRowRDD [54562] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141695 { id="cluster_141695"; isCluster="true"; label="WholeStageCodegen (4)"; 54563 [id="node_54563" labelType="html" label="MapPartitionsRDD [54563] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141733 { id="cluster_141733"; isCluster="true"; label="Exchange"; 54566 [id="node_54566" labelType="html" label="ShuffledRowRDD [54566] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141730 { id="cluster_141730"; isCluster="true"; label="WholeStageCodegen (6)"; 54567 [id="node_54567" labelType="html" label="MapPartitionsRDD [54567] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141687 { id="cluster_141687"; isCluster="true"; label="WholeStageCodegen (7)"; 54568 [id="node_54568" labelType="html" label="ZippedPartitionsRDD2 [54568] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54569 [id="node_54569" labelType="html" label="MapPartitionsRDD [54569] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141686 { id="cluster_141686"; isCluster="true"; label="InMemoryTableScan"; 54570 [id="node_54570" labelType="html" label="MapPartitionsRDD [54570] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54571 [id="node_54571" labelType="html" label="*(7) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, cachedQty#1095181 AS qty#1095183, demandChannel#1095176, demandStream#1095177, cachedKpis#1095182 AS kpis#1095184]\n+- *(7) SortMergeJoin [worklistShardItemId#1011816L, shardId#1011815], [cachedWorklistShardItemId#1095180L, cachedShardId#1095179], 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=1697422]\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... [54571] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141684 { id="cluster_141684"; isCluster="true"; label="Exchange"; 54578 [id="node_54578" labelType="html" label="ShuffledRowRDD [54578] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141681 { id="cluster_141681"; isCluster="true"; label="WholeStageCodegen (4)"; 54579 [id="node_54579" labelType="html" label="MapPartitionsRDD [54579] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141667 { id="cluster_141667"; isCluster="true"; label="WholeStageCodegen (5)"; 54580 [id="node_54580" labelType="html" label="ZippedPartitionsRDD2 [54580] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54581 [id="node_54581" labelType="html" label="MapPartitionsRDD [54581] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141748 { id="cluster_141748"; isCluster="true"; label="InMemoryTableScan"; 54582 [id="node_54582" labelType="html" label="MapPartitionsRDD [54582] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54583 [id="node_54583" labelType="html" label="MapPartitionsRDD [54583] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54584 [id="node_54584" labelType="html" label="MapPartitionsRDD [54584] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141745 { id="cluster_141745"; isCluster="true"; label="WholeStageCodegen (6)"; 54585 [id="node_54585" labelType="html" label="MapPartitionsRDD [54585] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141666 { id="cluster_141666"; isCluster="true"; label="Union"; 54586 [id="node_54586" labelType="html" label="UnionRDD [54586] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141665 { id="cluster_141665"; isCluster="true"; label="InMemoryTableScan"; 54587 [id="node_54587" labelType="html" label="MapPartitionsRDD [54587] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54588 [id="node_54588" labelType="html" label="Union\n:- *(5) Project [shardId#1011815, worklistShardItemId#1011816L, version#1011817, product#1011818, plant#1011819, qty#1011822, null AS demandChannel#1095416, null AS demandStream#1095417, [] AS kpis#1095451, true AS isNewlyCalculated#1095419]\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#1095408, ), isnull(shardId#1095408), coalesce(worklistShardItemId#1095409L, 0), isnull(worklistShardItemId#1095409L), coalesce(version#1095410, 0), isnull(version#1095410), coalesce(product#1095411, ), isnull(product#1095411), coalesce(plant#1095412, ), isnull(plant#1095412), knownfloatingpointnormalized(normalizenanandzero(coalesce... [54588] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141969 { id="cluster_141969"; isCluster="true"; label="InMemoryTableScan"; 54654 [id="node_54654" labelType="html" label="MapPartitionsRDD [54654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54655 [id="node_54655" labelType="html" label="MapPartitionsRDD [54655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54656 [id="node_54656" labelType="html" label="MapPartitionsRDD [54656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141964 { id="cluster_141964"; isCluster="true"; label="WholeStageCodegen (3)"; 54657 [id="node_54657" labelType="html" label="MapPartitionsRDD [54657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141963 { id="cluster_141963"; isCluster="true"; label="Exchange"; 54658 [id="node_54658" labelType="html" label="MapPartitionsRDD [54658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54550->54551; 54562->54563; 54566->54567; 54563->54568; 54567->54568; 54568->54569; 54569->54570; 54570->54571; 54578->54579; 54551->54580; 54579->54580; 54580->54581; 54571->54582; 54582->54583; 54583->54584; 54584->54585; 54581->54586; 54585->54586; 54586->54587; 54587->54588; 54588->54654; 54654->54655; 54655->54656; 54656->54657; 54657->54658; }