digraph G { id="graph_98491"; subgraph graph_stage_98491 { id="graph_stage_98491"; isCluster="true"; label="Stage 98491"; 44881 [id="node_44881" labelType="html" label="SQLExecutionRDD [44881] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_116413 { id="cluster_116413"; isCluster="true"; label="Exchange"; 44872 [id="node_44872" labelType="html" label="ShuffledRowRDD [44872] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116408 { id="cluster_116408"; isCluster="true"; label="WholeStageCodegen (6)"; 44873 [id="node_44873" labelType="html" label="MapPartitionsRDD [44873] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116407 { id="cluster_116407"; isCluster="true"; label="SortAggregate"; 44874 [id="node_44874" labelType="html" label="MapPartitionsRDD [44874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116406 { id="cluster_116406"; isCluster="true"; label="InMemoryTableScan"; 44875 [id="node_44875" labelType="html" label="MapPartitionsRDD [44875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44876 [id="node_44876" labelType="html" label="SortAggregate(key=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[first(kpis#902238, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#902229, demandChannel#902209, demandStream#902210, kpis#902371])\n+- *(6) Sort [demandChannel#902209 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#902229 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#902210 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, 37), ENSURE_REQUIREMENTS, [plan_id=1393658]\n +- SortAggregate(key=[demandChannel#902209, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#902229)) AS qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[partial_first(kpis#902238, false)], output=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, first#90244... [44876] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44877 [id="node_44877" labelType="html" label="MapPartitionsRDD [44877] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44878 [id="node_44878" labelType="html" label="MapPartitionsRDD [44878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44879 [id="node_44879" labelType="html" label="MapPartitionsRDD [44879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116405 { id="cluster_116405"; isCluster="true"; label="DeserializeToObject"; 44880 [id="node_44880" labelType="html" label="MapPartitionsRDD [44880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116462 { id="cluster_116462"; isCluster="true"; label="mapPartitions"; 44882 [id="node_44882" labelType="html" label="MapPartitionsRDD [44882] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44872->44873; 44873->44874; 44874->44875; 44875->44876; 44876->44877; 44877->44878; 44878->44879; 44879->44880; 44880->44881; 44881->44882; }