digraph G { id="graph_190615"; subgraph graph_stage_190615 { id="graph_stage_190615"; isCluster="true"; label="Stage 190615"; 424575 [id="node_424575" labelType="html" label="SQLExecutionRDD [424575] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1109612 { id="cluster_1109612"; isCluster="true"; label="Exchange"; 424566 [id="node_424566" labelType="html" label="ShuffledRowRDD [424566] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109609 { id="cluster_1109609"; isCluster="true"; label="WholeStageCodegen (7)"; 424567 [id="node_424567" labelType="html" label="MapPartitionsRDD [424567] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109608 { id="cluster_1109608"; isCluster="true"; label="SortAggregate"; 424568 [id="node_424568" labelType="html" label="MapPartitionsRDD [424568] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109607 { id="cluster_1109607"; isCluster="true"; label="InMemoryTableScan"; 424569 [id="node_424569" labelType="html" label="MapPartitionsRDD [424569] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424570 [id="node_424570" labelType="html" label="SortAggregate(key=[demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L, demandStream#6848124], functions=[first(kpis#6848152, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6848143, demandChannel#6848123, demandStream#6848124, kpis#6848265])\n+- *(7) Sort [demandChannel#6848123 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6848143 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6848124 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L, demandStream#6848124, 30), ENSURE_REQUIREMENTS, [plan_id=29058789]\n +- SortAggregate(key=[demandChannel#6848123, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6848143)) AS qty#6848143, worklistShardItemId#6552522L, demandStream#6848124], functions=[partial_first(kpis#6848152, false)], output=[demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L... [424570] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424571 [id="node_424571" labelType="html" label="MapPartitionsRDD [424571] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424572 [id="node_424572" labelType="html" label="MapPartitionsRDD [424572] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 424573 [id="node_424573" labelType="html" label="MapPartitionsRDD [424573] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109606 { id="cluster_1109606"; isCluster="true"; label="DeserializeToObject"; 424574 [id="node_424574" labelType="html" label="MapPartitionsRDD [424574] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109657 { id="cluster_1109657"; isCluster="true"; label="mapPartitions"; 424576 [id="node_424576" labelType="html" label="MapPartitionsRDD [424576] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 424566->424567; 424567->424568; 424568->424569; 424569->424570; 424570->424571; 424571->424572; 424572->424573; 424573->424574; 424574->424575; 424575->424576; }