digraph G { id="graph_1077"; subgraph graph_stage_1077 { id="graph_stage_1077"; isCluster="true"; label="Stage 1077"; 1652 [id="node_1652" labelType="html" label="SQLExecutionRDD [1652] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_4225 { id="cluster_4225"; isCluster="true"; label="Exchange"; 1643 [id="node_1643" labelType="html" label="ShuffledRowRDD [1643] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4222 { id="cluster_4222"; isCluster="true"; label="WholeStageCodegen (8)"; 1644 [id="node_1644" labelType="html" label="MapPartitionsRDD [1644] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4221 { id="cluster_4221"; isCluster="true"; label="SortAggregate"; 1645 [id="node_1645" labelType="html" label="MapPartitionsRDD [1645] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4220 { id="cluster_4220"; isCluster="true"; label="InMemoryTableScan"; 1646 [id="node_1646" labelType="html" label="MapPartitionsRDD [1646] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1647 [id="node_1647" labelType="html" label="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)], output=[shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27425])\n+- *(8) Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]\n +- SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)], output=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502])\n +- *(7) Sort [demandChannel#272... [1647] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1648 [id="node_1648" labelType="html" label="MapPartitionsRDD [1648] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1649 [id="node_1649" labelType="html" label="MapPartitionsRDD [1649] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1650 [id="node_1650" labelType="html" label="MapPartitionsRDD [1650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4219 { id="cluster_4219"; isCluster="true"; label="DeserializeToObject"; 1651 [id="node_1651" labelType="html" label="MapPartitionsRDD [1651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4275 { id="cluster_4275"; isCluster="true"; label="mapPartitions"; 1653 [id="node_1653" labelType="html" label="MapPartitionsRDD [1653] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1647->1648; 1648->1649; 1649->1650; 1650->1651; 1651->1652; 1652->1653; }