digraph G { id="graph_241144"; subgraph graph_stage_241144 { id="graph_stage_241144"; isCluster="true"; label="Stage 241144"; 539609 [id="node_539609" labelType="html" label="SQLExecutionRDD [539609] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1409217 { id="cluster_1409217"; isCluster="true"; label="Exchange"; 539600 [id="node_539600" labelType="html" label="ShuffledRowRDD [539600] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409214 { id="cluster_1409214"; isCluster="true"; label="WholeStageCodegen (7)"; 539601 [id="node_539601" labelType="html" label="MapPartitionsRDD [539601] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409213 { id="cluster_1409213"; isCluster="true"; label="SortAggregate"; 539602 [id="node_539602" labelType="html" label="MapPartitionsRDD [539602] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409212 { id="cluster_1409212"; isCluster="true"; label="InMemoryTableScan"; 539603 [id="node_539603" labelType="html" label="MapPartitionsRDD [539603] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539604 [id="node_539604" labelType="html" label="SortAggregate(key=[demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L, demandStream#8700790], functions=[first(kpis#8700818, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8700809, demandChannel#8700789, demandStream#8700790, kpis#8700931])\n+- *(7) Sort [demandChannel#8700789 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8700809 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8700790 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L, demandStream#8700790, 30), ENSURE_REQUIREMENTS, [plan_id=36540727]\n +- SortAggregate(key=[demandChannel#8700789, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8700809)) AS qty#8700809, worklistShardItemId#8398781L, demandStream#8700790], functions=[partial_first(kpis#8700818, false)], output=[demandChannel#8700789, shardId#8398780, qty#8700809, worklistShardItemId#8398781L... [539604] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539605 [id="node_539605" labelType="html" label="MapPartitionsRDD [539605] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539606 [id="node_539606" labelType="html" label="MapPartitionsRDD [539606] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539607 [id="node_539607" labelType="html" label="MapPartitionsRDD [539607] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409211 { id="cluster_1409211"; isCluster="true"; label="DeserializeToObject"; 539608 [id="node_539608" labelType="html" label="MapPartitionsRDD [539608] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409262 { id="cluster_1409262"; isCluster="true"; label="mapPartitions"; 539610 [id="node_539610" labelType="html" label="MapPartitionsRDD [539610] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 539600->539601; 539601->539602; 539602->539603; 539603->539604; 539604->539605; 539605->539606; 539606->539607; 539607->539608; 539608->539609; 539609->539610; }