digraph G { id="graph_90435"; subgraph graph_stage_90435 { id="graph_stage_90435"; isCluster="true"; label="Stage 90435"; 41949 [id="node_41949" labelType="html" label="SQLExecutionRDD [41949] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_109512 { id="cluster_109512"; isCluster="true"; label="Exchange"; 41940 [id="node_41940" labelType="html" label="ShuffledRowRDD [41940] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109507 { id="cluster_109507"; isCluster="true"; label="WholeStageCodegen (6)"; 41941 [id="node_41941" labelType="html" label="MapPartitionsRDD [41941] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109506 { id="cluster_109506"; isCluster="true"; label="SortAggregate"; 41942 [id="node_41942" labelType="html" label="MapPartitionsRDD [41942] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109505 { id="cluster_109505"; isCluster="true"; label="InMemoryTableScan"; 41943 [id="node_41943" labelType="html" label="MapPartitionsRDD [41943] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41944 [id="node_41944" labelType="html" label="SortAggregate(key=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[first(kpis#840779, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#840770, demandChannel#840750, demandStream#840751, kpis#840912])\n+- *(6) Sort [demandChannel#840750 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#840770 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#840751 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, 37), ENSURE_REQUIREMENTS, [plan_id=1376187]\n +- SortAggregate(key=[demandChannel#840750, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#840770)) AS qty#840770, worklistShardItemId#815741L, demandStream#840751], functions=[partial_first(kpis#840779, false)], output=[demandChannel#840750, shardId#815740, qty#840770, worklistShardItemId#815741L, demandStream#840751, first#84098... [41944] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41945 [id="node_41945" labelType="html" label="MapPartitionsRDD [41945] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41946 [id="node_41946" labelType="html" label="MapPartitionsRDD [41946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41947 [id="node_41947" labelType="html" label="MapPartitionsRDD [41947] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109504 { id="cluster_109504"; isCluster="true"; label="DeserializeToObject"; 41948 [id="node_41948" labelType="html" label="MapPartitionsRDD [41948] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109561 { id="cluster_109561"; isCluster="true"; label="mapPartitions"; 41950 [id="node_41950" labelType="html" label="MapPartitionsRDD [41950] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 41940->41941; 41941->41942; 41942->41943; 41943->41944; 41944->41945; 41945->41946; 41946->41947; 41947->41948; 41948->41949; 41949->41950; }