digraph G { id="graph_117081"; subgraph graph_stage_117081 { id="graph_stage_117081"; isCluster="true"; label="Stage 117081"; 56608 [id="node_56608" labelType="html" label="SQLExecutionRDD [56608] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_146930 { id="cluster_146930"; isCluster="true"; label="Exchange"; 56599 [id="node_56599" labelType="html" label="ShuffledRowRDD [56599] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146924 { id="cluster_146924"; isCluster="true"; label="WholeStageCodegen (6)"; 56600 [id="node_56600" labelType="html" label="MapPartitionsRDD [56600] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146923 { id="cluster_146923"; isCluster="true"; label="SortAggregate"; 56601 [id="node_56601" labelType="html" label="MapPartitionsRDD [56601] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146922 { id="cluster_146922"; isCluster="true"; label="InMemoryTableScan"; 56602 [id="node_56602" labelType="html" label="MapPartitionsRDD [56602] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56603 [id="node_56603" labelType="html" label="SortAggregate(key=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[first(kpis#1136802, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1136793, demandChannel#1136773, demandStream#1136774, kpis#1136935])\n+- *(6) Sort [demandChannel#1136773 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1136793 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1136774 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774, 37), ENSURE_REQUIREMENTS, [plan_id=1757887]\n +- SortAggregate(key=[demandChannel#1136773, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1136793)) AS qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[partial_first(kpis#1136802, false)], output=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L,... [56603] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56604 [id="node_56604" labelType="html" label="MapPartitionsRDD [56604] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56605 [id="node_56605" labelType="html" label="MapPartitionsRDD [56605] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56606 [id="node_56606" labelType="html" label="MapPartitionsRDD [56606] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146921 { id="cluster_146921"; isCluster="true"; label="DeserializeToObject"; 56607 [id="node_56607" labelType="html" label="MapPartitionsRDD [56607] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146978 { id="cluster_146978"; isCluster="true"; label="mapPartitions"; 56609 [id="node_56609" labelType="html" label="MapPartitionsRDD [56609] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56599->56600; 56600->56601; 56601->56602; 56602->56603; 56603->56604; 56604->56605; 56605->56606; 56606->56607; 56607->56608; 56608->56609; }