digraph G { id="graph_113764"; subgraph graph_stage_113764 { id="graph_stage_113764"; isCluster="true"; label="Stage 113764"; 54429 [id="node_54429" labelType="html" label="SQLExecutionRDD [54429] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_141334 { id="cluster_141334"; isCluster="true"; label="Exchange"; 54420 [id="node_54420" labelType="html" label="ShuffledRowRDD [54420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141328 { id="cluster_141328"; isCluster="true"; label="WholeStageCodegen (6)"; 54421 [id="node_54421" labelType="html" label="MapPartitionsRDD [54421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141327 { id="cluster_141327"; isCluster="true"; label="SortAggregate"; 54422 [id="node_54422" labelType="html" label="MapPartitionsRDD [54422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141326 { id="cluster_141326"; isCluster="true"; label="InMemoryTableScan"; 54423 [id="node_54423" labelType="html" label="MapPartitionsRDD [54423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54424 [id="node_54424" labelType="html" label="SortAggregate(key=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[first(kpis#1092423, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1092414, demandChannel#1092394, demandStream#1092395, kpis#1092556])\n+- *(6) Sort [demandChannel#1092394 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1092414 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1092395 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395, 37), ENSURE_REQUIREMENTS, [plan_id=1696762]\n +- SortAggregate(key=[demandChannel#1092394, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1092414)) AS qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[partial_first(kpis#1092423, false)], output=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L,... [54424] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54425 [id="node_54425" labelType="html" label="MapPartitionsRDD [54425] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54426 [id="node_54426" labelType="html" label="MapPartitionsRDD [54426] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54427 [id="node_54427" labelType="html" label="MapPartitionsRDD [54427] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141325 { id="cluster_141325"; isCluster="true"; label="DeserializeToObject"; 54428 [id="node_54428" labelType="html" label="MapPartitionsRDD [54428] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141382 { id="cluster_141382"; isCluster="true"; label="mapPartitions"; 54430 [id="node_54430" labelType="html" label="MapPartitionsRDD [54430] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54420->54421; 54421->54422; 54422->54423; 54423->54424; 54424->54425; 54425->54426; 54426->54427; 54427->54428; 54428->54429; 54429->54430; }