digraph G { id="graph_189878"; subgraph graph_stage_189878 { id="graph_stage_189878"; isCluster="true"; label="Stage 189878"; 422652 [id="node_422652" labelType="html" label="SQLExecutionRDD [422652] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1104817 { id="cluster_1104817"; isCluster="true"; label="Exchange"; 422643 [id="node_422643" labelType="html" label="ShuffledRowRDD [422643] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104814 { id="cluster_1104814"; isCluster="true"; label="WholeStageCodegen (7)"; 422644 [id="node_422644" labelType="html" label="MapPartitionsRDD [422644] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104813 { id="cluster_1104813"; isCluster="true"; label="SortAggregate"; 422645 [id="node_422645" labelType="html" label="MapPartitionsRDD [422645] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104812 { id="cluster_1104812"; isCluster="true"; label="InMemoryTableScan"; 422646 [id="node_422646" labelType="html" label="MapPartitionsRDD [422646] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422647 [id="node_422647" labelType="html" label="SortAggregate(key=[demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L, demandStream#6818188], functions=[first(kpis#6818216, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6818207, demandChannel#6818187, demandStream#6818188, kpis#6818329])\n+- *(7) Sort [demandChannel#6818187 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6818207 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6818188 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L, demandStream#6818188, 30), ENSURE_REQUIREMENTS, [plan_id=29046855]\n +- SortAggregate(key=[demandChannel#6818187, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6818207)) AS qty#6818207, worklistShardItemId#6552498L, demandStream#6818188], functions=[partial_first(kpis#6818216, false)], output=[demandChannel#6818187, shardId#6552497, qty#6818207, worklistShardItemId#6552498L... [422647] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422648 [id="node_422648" labelType="html" label="MapPartitionsRDD [422648] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422649 [id="node_422649" labelType="html" label="MapPartitionsRDD [422649] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422650 [id="node_422650" labelType="html" label="MapPartitionsRDD [422650] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104811 { id="cluster_1104811"; isCluster="true"; label="DeserializeToObject"; 422651 [id="node_422651" labelType="html" label="MapPartitionsRDD [422651] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104862 { id="cluster_1104862"; isCluster="true"; label="mapPartitions"; 422653 [id="node_422653" labelType="html" label="MapPartitionsRDD [422653] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 422643->422644; 422644->422645; 422645->422646; 422646->422647; 422647->422648; 422648->422649; 422649->422650; 422650->422651; 422651->422652; 422652->422653; }