digraph G { id="graph_190324"; subgraph graph_stage_190324 { id="graph_stage_190324"; isCluster="true"; label="Stage 190324"; 423792 [id="node_423792" labelType="html" label="SQLExecutionRDD [423792] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1107689 { id="cluster_1107689"; isCluster="true"; label="Exchange"; 423783 [id="node_423783" labelType="html" label="ShuffledRowRDD [423783] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107686 { id="cluster_1107686"; isCluster="true"; label="WholeStageCodegen (7)"; 423784 [id="node_423784" labelType="html" label="MapPartitionsRDD [423784] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107685 { id="cluster_1107685"; isCluster="true"; label="SortAggregate"; 423785 [id="node_423785" labelType="html" label="MapPartitionsRDD [423785] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107684 { id="cluster_1107684"; isCluster="true"; label="InMemoryTableScan"; 423786 [id="node_423786" labelType="html" label="MapPartitionsRDD [423786] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423787 [id="node_423787" labelType="html" label="SortAggregate(key=[demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L, demandStream#6835890], functions=[first(kpis#6835918, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6835909, demandChannel#6835889, demandStream#6835890, kpis#6836031])\n+- *(7) Sort [demandChannel#6835889 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6835909 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6835890 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L, demandStream#6835890, 30), ENSURE_REQUIREMENTS, [plan_id=29053926]\n +- SortAggregate(key=[demandChannel#6835889, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6835909)) AS qty#6835909, worklistShardItemId#6552522L, demandStream#6835890], functions=[partial_first(kpis#6835918, false)], output=[demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L... [423787] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423788 [id="node_423788" labelType="html" label="MapPartitionsRDD [423788] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423789 [id="node_423789" labelType="html" label="MapPartitionsRDD [423789] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423790 [id="node_423790" labelType="html" label="MapPartitionsRDD [423790] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107683 { id="cluster_1107683"; isCluster="true"; label="DeserializeToObject"; 423791 [id="node_423791" labelType="html" label="MapPartitionsRDD [423791] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107734 { id="cluster_1107734"; isCluster="true"; label="mapPartitions"; 423793 [id="node_423793" labelType="html" label="MapPartitionsRDD [423793] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 423783->423784; 423784->423785; 423785->423786; 423786->423787; 423787->423788; 423788->423789; 423789->423790; 423790->423791; 423791->423792; 423792->423793; }