digraph G { id="graph_191017"; subgraph graph_stage_191017 { id="graph_stage_191017"; isCluster="true"; label="Stage 191017"; 425686 [id="node_425686" labelType="html" label="SQLExecutionRDD [425686] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1112324 { id="cluster_1112324"; isCluster="true"; label="Exchange"; 425677 [id="node_425677" labelType="html" label="ShuffledRowRDD [425677] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112321 { id="cluster_1112321"; isCluster="true"; label="WholeStageCodegen (7)"; 425678 [id="node_425678" labelType="html" label="MapPartitionsRDD [425678] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112320 { id="cluster_1112320"; isCluster="true"; label="SortAggregate"; 425679 [id="node_425679" labelType="html" label="MapPartitionsRDD [425679] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112319 { id="cluster_1112319"; isCluster="true"; label="InMemoryTableScan"; 425680 [id="node_425680" labelType="html" label="MapPartitionsRDD [425680] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425681 [id="node_425681" labelType="html" label="SortAggregate(key=[demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L, demandStream#6865299], functions=[first(kpis#6865327, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6865318, demandChannel#6865298, demandStream#6865299, kpis#6865440])\n+- *(7) Sort [demandChannel#6865298 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6865318 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6865299 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L, demandStream#6865299, 30), ENSURE_REQUIREMENTS, [plan_id=29065545]\n +- SortAggregate(key=[demandChannel#6865298, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6865318)) AS qty#6865318, worklistShardItemId#6552522L, demandStream#6865299], functions=[partial_first(kpis#6865327, false)], output=[demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L... [425681] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425682 [id="node_425682" labelType="html" label="MapPartitionsRDD [425682] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425683 [id="node_425683" labelType="html" label="MapPartitionsRDD [425683] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425684 [id="node_425684" labelType="html" label="MapPartitionsRDD [425684] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112318 { id="cluster_1112318"; isCluster="true"; label="DeserializeToObject"; 425685 [id="node_425685" labelType="html" label="MapPartitionsRDD [425685] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112369 { id="cluster_1112369"; isCluster="true"; label="mapPartitions"; 425687 [id="node_425687" labelType="html" label="MapPartitionsRDD [425687] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425677->425678; 425678->425679; 425679->425680; 425680->425681; 425681->425682; 425682->425683; 425683->425684; 425684->425685; 425685->425686; 425686->425687; }