digraph G { id="graph_105147"; subgraph graph_stage_105147 { id="graph_stage_105147"; isCluster="true"; label="Stage 105147"; 50390 [id="node_50390" labelType="html" label="SQLExecutionRDD [50390] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_131274 { id="cluster_131274"; isCluster="true"; label="Exchange"; 50381 [id="node_50381" labelType="html" label="ShuffledRowRDD [50381] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131269 { id="cluster_131269"; isCluster="true"; label="WholeStageCodegen (6)"; 50382 [id="node_50382" labelType="html" label="MapPartitionsRDD [50382] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131268 { id="cluster_131268"; isCluster="true"; label="SortAggregate"; 50383 [id="node_50383" labelType="html" label="MapPartitionsRDD [50383] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131267 { id="cluster_131267"; isCluster="true"; label="InMemoryTableScan"; 50384 [id="node_50384" labelType="html" label="MapPartitionsRDD [50384] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50385 [id="node_50385" labelType="html" label="SortAggregate(key=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[first(kpis#1009339, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#1009330, demandChannel#1009310, demandStream#1009311, kpis#1009472])\n+- *(6) Sort [demandChannel#1009310 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#1009330 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#1009311 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStream#1009311, 37), ENSURE_REQUIREMENTS, [plan_id=1632985]\n +- SortAggregate(key=[demandChannel#1009310, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#1009330)) AS qty#1009330, worklistShardItemId#943632L, demandStream#1009311], functions=[partial_first(kpis#1009339, false)], output=[demandChannel#1009310, shardId#943631, qty#1009330, worklistShardItemId#943632L, demandStrea... [50385] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50386 [id="node_50386" labelType="html" label="MapPartitionsRDD [50386] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50387 [id="node_50387" labelType="html" label="MapPartitionsRDD [50387] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50388 [id="node_50388" labelType="html" label="MapPartitionsRDD [50388] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131266 { id="cluster_131266"; isCluster="true"; label="DeserializeToObject"; 50389 [id="node_50389" labelType="html" label="MapPartitionsRDD [50389] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131323 { id="cluster_131323"; isCluster="true"; label="mapPartitions"; 50391 [id="node_50391" labelType="html" label="MapPartitionsRDD [50391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50381->50382; 50382->50383; 50383->50384; 50384->50385; 50385->50386; 50386->50387; 50387->50388; 50388->50389; 50389->50390; 50390->50391; }