digraph G { id="graph_191308"; subgraph graph_stage_191308 { id="graph_stage_191308"; isCluster="true"; label="Stage 191308"; 426470 [id="node_426470" labelType="html" label="SQLExecutionRDD [426470] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1114279 { id="cluster_1114279"; isCluster="true"; label="Exchange"; 426461 [id="node_426461" labelType="html" label="ShuffledRowRDD [426461] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114276 { id="cluster_1114276"; isCluster="true"; label="WholeStageCodegen (7)"; 426462 [id="node_426462" labelType="html" label="MapPartitionsRDD [426462] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114275 { id="cluster_1114275"; isCluster="true"; label="SortAggregate"; 426463 [id="node_426463" labelType="html" label="MapPartitionsRDD [426463] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114274 { id="cluster_1114274"; isCluster="true"; label="InMemoryTableScan"; 426464 [id="node_426464" labelType="html" label="MapPartitionsRDD [426464] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426465 [id="node_426465" labelType="html" label="SortAggregate(key=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[first(kpis#6877384, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6877375, demandChannel#6877355, demandStream#6877356, kpis#6877497])\n+- *(7) Sort [demandChannel#6877355 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6877375 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6877356 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L, demandStream#6877356, 30), ENSURE_REQUIREMENTS, [plan_id=29070493]\n +- SortAggregate(key=[demandChannel#6877355, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6877375)) AS qty#6877375, worklistShardItemId#6552522L, demandStream#6877356], functions=[partial_first(kpis#6877384, false)], output=[demandChannel#6877355, shardId#6552521, qty#6877375, worklistShardItemId#6552522L... [426465] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426466 [id="node_426466" labelType="html" label="MapPartitionsRDD [426466] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426467 [id="node_426467" labelType="html" label="MapPartitionsRDD [426467] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426468 [id="node_426468" labelType="html" label="MapPartitionsRDD [426468] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114273 { id="cluster_1114273"; isCluster="true"; label="DeserializeToObject"; 426469 [id="node_426469" labelType="html" label="MapPartitionsRDD [426469] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1114324 { id="cluster_1114324"; isCluster="true"; label="mapPartitions"; 426471 [id="node_426471" labelType="html" label="MapPartitionsRDD [426471] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 426461->426462; 426462->426463; 426463->426464; 426464->426465; 426465->426466; 426466->426467; 426467->426468; 426468->426469; 426469->426470; 426470->426471; }