digraph G { id="graph_191211"; subgraph graph_stage_191211 { id="graph_stage_191211"; isCluster="true"; label="Stage 191211"; 426209 [id="node_426209" labelType="html" label="SQLExecutionRDD [426209] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1113637 { id="cluster_1113637"; isCluster="true"; label="Exchange"; 426200 [id="node_426200" labelType="html" label="ShuffledRowRDD [426200] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113634 { id="cluster_1113634"; isCluster="true"; label="WholeStageCodegen (7)"; 426201 [id="node_426201" labelType="html" label="MapPartitionsRDD [426201] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113633 { id="cluster_1113633"; isCluster="true"; label="SortAggregate"; 426202 [id="node_426202" labelType="html" label="MapPartitionsRDD [426202] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113632 { id="cluster_1113632"; isCluster="true"; label="InMemoryTableScan"; 426203 [id="node_426203" labelType="html" label="MapPartitionsRDD [426203] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426204 [id="node_426204" labelType="html" label="SortAggregate(key=[demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[first(kpis#6873317, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873430])\n+- *(7) Sort [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, 30), ENSURE_REQUIREMENTS, [plan_id=29068862]\n +- SortAggregate(key=[demandChannel#6873288, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[partial_first(kpis#6873317, false)], output=[demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L... [426204] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426205 [id="node_426205" labelType="html" label="MapPartitionsRDD [426205] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426206 [id="node_426206" labelType="html" label="MapPartitionsRDD [426206] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 426207 [id="node_426207" labelType="html" label="MapPartitionsRDD [426207] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113631 { id="cluster_1113631"; isCluster="true"; label="DeserializeToObject"; 426208 [id="node_426208" labelType="html" label="MapPartitionsRDD [426208] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113682 { id="cluster_1113682"; isCluster="true"; label="mapPartitions"; 426210 [id="node_426210" labelType="html" label="MapPartitionsRDD [426210] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 426200->426201; 426201->426202; 426202->426203; 426203->426204; 426204->426205; 426205->426206; 426206->426207; 426207->426208; 426208->426209; 426209->426210; }