digraph G { id="graph_241396"; subgraph graph_stage_241396 { id="graph_stage_241396"; isCluster="true"; label="Stage 241396"; 540235 [id="node_540235" labelType="html" label="SQLExecutionRDD [540235] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1410827 { id="cluster_1410827"; isCluster="true"; label="Exchange"; 540226 [id="node_540226" labelType="html" label="ShuffledRowRDD [540226] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410824 { id="cluster_1410824"; isCluster="true"; label="WholeStageCodegen (7)"; 540227 [id="node_540227" labelType="html" label="MapPartitionsRDD [540227] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410823 { id="cluster_1410823"; isCluster="true"; label="SortAggregate"; 540228 [id="node_540228" labelType="html" label="MapPartitionsRDD [540228] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410822 { id="cluster_1410822"; isCluster="true"; label="InMemoryTableScan"; 540229 [id="node_540229" labelType="html" label="MapPartitionsRDD [540229] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 540230 [id="node_540230" labelType="html" label="SortAggregate(key=[demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L, demandStream#8710382], functions=[first(kpis#8710410, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8710401, demandChannel#8710381, demandStream#8710382, kpis#8710523])\n+- *(7) Sort [demandChannel#8710381 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8710401 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8710382 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L, demandStream#8710382, 30), ENSURE_REQUIREMENTS, [plan_id=36544648]\n +- SortAggregate(key=[demandChannel#8710381, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8710401)) AS qty#8710401, worklistShardItemId#8398781L, demandStream#8710382], functions=[partial_first(kpis#8710410, false)], output=[demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L... [540230] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 540231 [id="node_540231" labelType="html" label="MapPartitionsRDD [540231] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 540232 [id="node_540232" labelType="html" label="MapPartitionsRDD [540232] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 540233 [id="node_540233" labelType="html" label="MapPartitionsRDD [540233] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410821 { id="cluster_1410821"; isCluster="true"; label="DeserializeToObject"; 540234 [id="node_540234" labelType="html" label="MapPartitionsRDD [540234] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410872 { id="cluster_1410872"; isCluster="true"; label="mapPartitions"; 540236 [id="node_540236" labelType="html" label="MapPartitionsRDD [540236] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 540226->540227; 540227->540228; 540228->540229; 540229->540230; 540230->540231; 540231->540232; 540232->540233; 540233->540234; 540234->540235; 540235->540236; }