digraph G { id="graph_114431"; subgraph graph_stage_114431 { id="graph_stage_114431"; isCluster="true"; label="Stage 114431"; 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_141876 { id="cluster_141876"; isCluster="true"; label="Exchange"; 54633 [id="node_54633" labelType="html" label="ShuffledRowRDD [54633] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141875 { id="cluster_141875"; isCluster="true"; label="ObjectHashAggregate"; 54634 [id="node_54634" labelType="html" label="MapPartitionsRDD [54634] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141887 { id="cluster_141887"; isCluster="true"; label="InMemoryTableScan"; 54635 [id="node_54635" labelType="html" label="MapPartitionsRDD [54635] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54636 [id="node_54636" labelType="html" label="MapPartitionsRDD [54636] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54637 [id="node_54637" labelType="html" label="MapPartitionsRDD [54637] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141883 { id="cluster_141883"; isCluster="true"; label="WholeStageCodegen (12)"; 54638 [id="node_54638" labelType="html" label="MapPartitionsRDD [54638] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141874 { id="cluster_141874"; isCluster="true"; label="Union"; 54639 [id="node_54639" labelType="html" label="UnionRDD [54639] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141873 { id="cluster_141873"; isCluster="true"; label="Exchange"; 54640 [id="node_54640" labelType="html" label="MapPartitionsRDD [54640] [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; 54633->54634; 54588->54635; 54635->54636; 54636->54637; 54637->54638; 54634->54639; 54638->54639; 54639->54640; }