digraph G { id="graph_94805"; subgraph graph_stage_94805 { id="graph_stage_94805"; isCluster="true"; label="Stage 94805"; 43269 [id="node_43269" labelType="html" label="SQLExecutionRDD [43269] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_112617 { id="cluster_112617"; isCluster="true"; label="Exchange"; 43260 [id="node_43260" labelType="html" label="ShuffledRowRDD [43260] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112612 { id="cluster_112612"; isCluster="true"; label="WholeStageCodegen (6)"; 43261 [id="node_43261" labelType="html" label="MapPartitionsRDD [43261] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112611 { id="cluster_112611"; isCluster="true"; label="SortAggregate"; 43262 [id="node_43262" labelType="html" label="MapPartitionsRDD [43262] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112610 { id="cluster_112610"; isCluster="true"; label="InMemoryTableScan"; 43263 [id="node_43263" labelType="html" label="MapPartitionsRDD [43263] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43264 [id="node_43264" labelType="html" label="SortAggregate(key=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[first(kpis#868569, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#868560, demandChannel#868540, demandStream#868541, kpis#868702])\n+- *(6) Sort [demandChannel#868540 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#868560 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#868541 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, 37), ENSURE_REQUIREMENTS, [plan_id=1384066]\n +- SortAggregate(key=[demandChannel#868540, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#868560)) AS qty#868560, worklistShardItemId#815741L, demandStream#868541], functions=[partial_first(kpis#868569, false)], output=[demandChannel#868540, shardId#815740, qty#868560, worklistShardItemId#815741L, demandStream#868541, first#86877... [43264] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43265 [id="node_43265" labelType="html" label="MapPartitionsRDD [43265] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43266 [id="node_43266" labelType="html" label="MapPartitionsRDD [43266] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 43267 [id="node_43267" labelType="html" label="MapPartitionsRDD [43267] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112609 { id="cluster_112609"; isCluster="true"; label="DeserializeToObject"; 43268 [id="node_43268" labelType="html" label="MapPartitionsRDD [43268] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_112666 { id="cluster_112666"; isCluster="true"; label="mapPartitions"; 43270 [id="node_43270" labelType="html" label="MapPartitionsRDD [43270] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 43260->43261; 43261->43262; 43262->43263; 43263->43264; 43264->43265; 43265->43266; 43266->43267; 43267->43268; 43268->43269; 43269->43270; }