digraph G { id="graph_189925"; subgraph graph_stage_189925 { id="graph_stage_189925"; isCluster="true"; label="Stage 189925"; 422725 [id="node_422725" labelType="html" label="SQLExecutionRDD [422725] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1105059 { id="cluster_1105059"; isCluster="true"; label="Exchange"; 422716 [id="node_422716" labelType="html" label="ShuffledRowRDD [422716] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105056 { id="cluster_1105056"; isCluster="true"; label="WholeStageCodegen (7)"; 422717 [id="node_422717" labelType="html" label="MapPartitionsRDD [422717] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105055 { id="cluster_1105055"; isCluster="true"; label="SortAggregate"; 422718 [id="node_422718" labelType="html" label="MapPartitionsRDD [422718] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105054 { id="cluster_1105054"; isCluster="true"; label="InMemoryTableScan"; 422719 [id="node_422719" labelType="html" label="MapPartitionsRDD [422719] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422720 [id="node_422720" labelType="html" label="SortAggregate(key=[demandChannel#6819473, shardId#6552473, qty#6819493, worklistShardItemId#6552474L, demandStream#6819474], functions=[first(kpis#6819502, false)], output=[shardId#6552473, worklistShardItemId#6552474L, qty#6819493, demandChannel#6819473, demandStream#6819474, kpis#6819615])\n+- *(7) Sort [demandChannel#6819473 ASC NULLS FIRST, shardId#6552473 ASC NULLS FIRST, qty#6819493 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST, demandStream#6819474 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6819473, shardId#6552473, qty#6819493, worklistShardItemId#6552474L, demandStream#6819474, 30), ENSURE_REQUIREMENTS, [plan_id=29047148]\n +- SortAggregate(key=[demandChannel#6819473, shardId#6552473, knownfloatingpointnormalized(normalizenanandzero(qty#6819493)) AS qty#6819493, worklistShardItemId#6552474L, demandStream#6819474], functions=[partial_first(kpis#6819502, false)], output=[demandChannel#6819473, shardId#6552473, qty#6819493, worklistShardItemId#6552474L... [422720] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422721 [id="node_422721" labelType="html" label="MapPartitionsRDD [422721] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422722 [id="node_422722" labelType="html" label="MapPartitionsRDD [422722] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 422723 [id="node_422723" labelType="html" label="MapPartitionsRDD [422723] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105053 { id="cluster_1105053"; isCluster="true"; label="DeserializeToObject"; 422724 [id="node_422724" labelType="html" label="MapPartitionsRDD [422724] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1105104 { id="cluster_1105104"; isCluster="true"; label="mapPartitions"; 422726 [id="node_422726" labelType="html" label="MapPartitionsRDD [422726] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 422716->422717; 422717->422718; 422718->422719; 422719->422720; 422720->422721; 422721->422722; 422722->422723; 422723->422724; 422724->422725; 422725->422726; }