digraph G { id="graph_119829"; subgraph graph_stage_119829 { id="graph_stage_119829"; isCluster="true"; label="Stage 119829"; 57928 [id="node_57928" labelType="html" label="SQLExecutionRDD [57928] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_150035 { id="cluster_150035"; isCluster="true"; label="Exchange"; 57919 [id="node_57919" labelType="html" label="ShuffledRowRDD [57919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150029 { id="cluster_150029"; isCluster="true"; label="WholeStageCodegen (6)"; 57920 [id="node_57920" labelType="html" label="MapPartitionsRDD [57920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150028 { id="cluster_150028"; isCluster="true"; label="SortAggregate"; 57921 [id="node_57921" labelType="html" label="MapPartitionsRDD [57921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150027 { id="cluster_150027"; isCluster="true"; label="InMemoryTableScan"; 57922 [id="node_57922" labelType="html" label="MapPartitionsRDD [57922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57923 [id="node_57923" labelType="html" label="SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])\n+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]\n +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,... [57923] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57924 [id="node_57924" labelType="html" label="MapPartitionsRDD [57924] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57925 [id="node_57925" labelType="html" label="MapPartitionsRDD [57925] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57926 [id="node_57926" labelType="html" label="MapPartitionsRDD [57926] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150026 { id="cluster_150026"; isCluster="true"; label="DeserializeToObject"; 57927 [id="node_57927" labelType="html" label="MapPartitionsRDD [57927] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150083 { id="cluster_150083"; isCluster="true"; label="mapPartitions"; 57929 [id="node_57929" labelType="html" label="MapPartitionsRDD [57929] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57919->57920; 57920->57921; 57921->57922; 57922->57923; 57923->57924; 57924->57925; 57925->57926; 57926->57927; 57927->57928; 57928->57929; }