digraph G { id="graph_241299"; subgraph graph_stage_241299 { id="graph_stage_241299"; isCluster="true"; label="Stage 241299"; 539970 [id="node_539970" labelType="html" label="SQLExecutionRDD [539970] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1410176 { id="cluster_1410176"; isCluster="true"; label="Exchange"; 539961 [id="node_539961" labelType="html" label="ShuffledRowRDD [539961] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410173 { id="cluster_1410173"; isCluster="true"; label="WholeStageCodegen (7)"; 539962 [id="node_539962" labelType="html" label="MapPartitionsRDD [539962] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410172 { id="cluster_1410172"; isCluster="true"; label="SortAggregate"; 539963 [id="node_539963" labelType="html" label="MapPartitionsRDD [539963] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410171 { id="cluster_1410171"; isCluster="true"; label="InMemoryTableScan"; 539964 [id="node_539964" labelType="html" label="MapPartitionsRDD [539964] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539965 [id="node_539965" labelType="html" label="SortAggregate(key=[demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L, demandStream#8706281], functions=[first(kpis#8706309, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8706300, demandChannel#8706280, demandStream#8706281, kpis#8706422])\n+- *(7) Sort [demandChannel#8706280 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8706300 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8706281 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L, demandStream#8706281, 30), ENSURE_REQUIREMENTS, [plan_id=36542996]\n +- SortAggregate(key=[demandChannel#8706280, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8706300)) AS qty#8706300, worklistShardItemId#8398781L, demandStream#8706281], functions=[partial_first(kpis#8706309, false)], output=[demandChannel#8706280, shardId#8398780, qty#8706300, worklistShardItemId#8398781L... [539965] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539966 [id="node_539966" labelType="html" label="MapPartitionsRDD [539966] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539967 [id="node_539967" labelType="html" label="MapPartitionsRDD [539967] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 539968 [id="node_539968" labelType="html" label="MapPartitionsRDD [539968] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410170 { id="cluster_1410170"; isCluster="true"; label="DeserializeToObject"; 539969 [id="node_539969" labelType="html" label="MapPartitionsRDD [539969] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410221 { id="cluster_1410221"; isCluster="true"; label="mapPartitions"; 539971 [id="node_539971" labelType="html" label="MapPartitionsRDD [539971] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 539961->539962; 539962->539963; 539963->539964; 539964->539965; 539965->539966; 539966->539967; 539967->539968; 539968->539969; 539969->539970; 539970->539971; }