digraph G { id="graph_90985"; subgraph graph_stage_90985 { id="graph_stage_90985"; isCluster="true"; label="Stage 90985"; 42213 [id="node_42213" labelType="html" label="SQLExecutionRDD [42213] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_110133 { id="cluster_110133"; isCluster="true"; label="Exchange"; 42204 [id="node_42204" labelType="html" label="ShuffledRowRDD [42204] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110128 { id="cluster_110128"; isCluster="true"; label="WholeStageCodegen (6)"; 42205 [id="node_42205" labelType="html" label="MapPartitionsRDD [42205] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110127 { id="cluster_110127"; isCluster="true"; label="SortAggregate"; 42206 [id="node_42206" labelType="html" label="MapPartitionsRDD [42206] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110126 { id="cluster_110126"; isCluster="true"; label="InMemoryTableScan"; 42207 [id="node_42207" labelType="html" label="MapPartitionsRDD [42207] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42208 [id="node_42208" labelType="html" label="SortAggregate(key=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[first(kpis#846337, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#846328, demandChannel#846308, demandStream#846309, kpis#846470])\n+- *(6) Sort [demandChannel#846308 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#846328 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#846309 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, 37), ENSURE_REQUIREMENTS, [plan_id=1377777]\n +- SortAggregate(key=[demandChannel#846308, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#846328)) AS qty#846328, worklistShardItemId#815741L, demandStream#846309], functions=[partial_first(kpis#846337, false)], output=[demandChannel#846308, shardId#815740, qty#846328, worklistShardItemId#815741L, demandStream#846309, first#84654... [42208] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42209 [id="node_42209" labelType="html" label="MapPartitionsRDD [42209] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42210 [id="node_42210" labelType="html" label="MapPartitionsRDD [42210] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 42211 [id="node_42211" labelType="html" label="MapPartitionsRDD [42211] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110125 { id="cluster_110125"; isCluster="true"; label="DeserializeToObject"; 42212 [id="node_42212" labelType="html" label="MapPartitionsRDD [42212] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110182 { id="cluster_110182"; isCluster="true"; label="mapPartitions"; 42214 [id="node_42214" labelType="html" label="MapPartitionsRDD [42214] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42204->42205; 42205->42206; 42206->42207; 42207->42208; 42208->42209; 42209->42210; 42210->42211; 42211->42212; 42212->42213; 42213->42214; }