digraph G { id="graph_104273"; subgraph graph_stage_104273 { id="graph_stage_104273"; isCluster="true"; label="Stage 104273"; 50126 [id="node_50126" labelType="html" label="SQLExecutionRDD [50126] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_130654 { id="cluster_130654"; isCluster="true"; label="Exchange"; 50117 [id="node_50117" labelType="html" label="ShuffledRowRDD [50117] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130648 { id="cluster_130648"; isCluster="true"; label="WholeStageCodegen (6)"; 50118 [id="node_50118" labelType="html" label="MapPartitionsRDD [50118] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130647 { id="cluster_130647"; isCluster="true"; label="SortAggregate"; 50119 [id="node_50119" labelType="html" label="MapPartitionsRDD [50119] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130646 { id="cluster_130646"; isCluster="true"; label="InMemoryTableScan"; 50120 [id="node_50120" labelType="html" label="MapPartitionsRDD [50120] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50121 [id="node_50121" labelType="html" label="SortAggregate(key=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[first(kpis#1003781, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1003772, demandChannel#1003752, demandStream#1003753, kpis#1003914])\n+- *(6) Sort [demandChannel#1003752 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1003772 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1003753 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStream#1003753, 37), ENSURE_REQUIREMENTS, [plan_id=1631410]\n +- SortAggregate(key=[demandChannel#1003752, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1003772)) AS qty#1003772, worklistShardItemId#943632L, demandStream#1003753], functions=[partial_first(kpis#1003781, false)], output=[demandChannel#1003752, shardId#943631, qty#1003772, worklistShardItemId#943632L, demandStrea... [50121] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50122 [id="node_50122" labelType="html" label="MapPartitionsRDD [50122] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50123 [id="node_50123" labelType="html" label="MapPartitionsRDD [50123] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50124 [id="node_50124" labelType="html" label="MapPartitionsRDD [50124] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130645 { id="cluster_130645"; isCluster="true"; label="DeserializeToObject"; 50125 [id="node_50125" labelType="html" label="MapPartitionsRDD [50125] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130702 { id="cluster_130702"; isCluster="true"; label="mapPartitions"; 50127 [id="node_50127" labelType="html" label="MapPartitionsRDD [50127] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50117->50118; 50118->50119; 50119->50120; 50120->50121; 50121->50122; 50122->50123; 50123->50124; 50124->50125; 50125->50126; 50126->50127; }