digraph G { id="graph_190227"; subgraph graph_stage_190227 { id="graph_stage_190227"; isCluster="true"; label="Stage 190227"; 423531 [id="node_423531" labelType="html" label="SQLExecutionRDD [423531] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1107048 { id="cluster_1107048"; isCluster="true"; label="Exchange"; 423522 [id="node_423522" labelType="html" label="ShuffledRowRDD [423522] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107045 { id="cluster_1107045"; isCluster="true"; label="WholeStageCodegen (7)"; 423523 [id="node_423523" labelType="html" label="MapPartitionsRDD [423523] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107044 { id="cluster_1107044"; isCluster="true"; label="SortAggregate"; 423524 [id="node_423524" labelType="html" label="MapPartitionsRDD [423524] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107043 { id="cluster_1107043"; isCluster="true"; label="InMemoryTableScan"; 423525 [id="node_423525" labelType="html" label="MapPartitionsRDD [423525] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423526 [id="node_423526" labelType="html" label="SortAggregate(key=[demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L, demandStream#6831812], functions=[first(kpis#6831840, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6831831, demandChannel#6831811, demandStream#6831812, kpis#6831953])\n+- *(7) Sort [demandChannel#6831811 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6831831 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6831812 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L, demandStream#6831812, 30), ENSURE_REQUIREMENTS, [plan_id=29052320]\n +- SortAggregate(key=[demandChannel#6831811, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6831831)) AS qty#6831831, worklistShardItemId#6552498L, demandStream#6831812], functions=[partial_first(kpis#6831840, false)], output=[demandChannel#6831811, shardId#6552497, qty#6831831, worklistShardItemId#6552498L... [423526] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423527 [id="node_423527" labelType="html" label="MapPartitionsRDD [423527] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423528 [id="node_423528" labelType="html" label="MapPartitionsRDD [423528] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423529 [id="node_423529" labelType="html" label="MapPartitionsRDD [423529] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107042 { id="cluster_1107042"; isCluster="true"; label="DeserializeToObject"; 423530 [id="node_423530" labelType="html" label="MapPartitionsRDD [423530] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107093 { id="cluster_1107093"; isCluster="true"; label="mapPartitions"; 423532 [id="node_423532" labelType="html" label="MapPartitionsRDD [423532] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 423522->423523; 423523->423524; 423524->423525; 423525->423526; 423526->423527; 423527->423528; 423528->423529; 423529->423530; 423530->423531; 423531->423532; }