digraph G { id="graph_103561"; subgraph graph_stage_103561 { id="graph_stage_103561"; isCluster="true"; label="Stage 103561"; 49862 [id="node_49862" labelType="html" label="SQLExecutionRDD [49862] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_130032 { id="cluster_130032"; isCluster="true"; label="Exchange"; 49853 [id="node_49853" labelType="html" label="ShuffledRowRDD [49853] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130027 { id="cluster_130027"; isCluster="true"; label="WholeStageCodegen (6)"; 49854 [id="node_49854" labelType="html" label="MapPartitionsRDD [49854] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130026 { id="cluster_130026"; isCluster="true"; label="SortAggregate"; 49855 [id="node_49855" labelType="html" label="MapPartitionsRDD [49855] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130025 { id="cluster_130025"; isCluster="true"; label="InMemoryTableScan"; 49856 [id="node_49856" labelType="html" label="MapPartitionsRDD [49856] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49857 [id="node_49857" labelType="html" label="SortAggregate(key=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[first(kpis#998223, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#998214, demandChannel#998194, demandStream#998195, kpis#998356])\n+- *(6) Sort [demandChannel#998194 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#998214 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#998195 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, 37), ENSURE_REQUIREMENTS, [plan_id=1629820]\n +- SortAggregate(key=[demandChannel#998194, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#998214)) AS qty#998214, worklistShardItemId#943632L, demandStream#998195], functions=[partial_first(kpis#998223, false)], output=[demandChannel#998194, shardId#943631, qty#998214, worklistShardItemId#943632L, demandStream#998195, first#99843... [49857] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49858 [id="node_49858" labelType="html" label="MapPartitionsRDD [49858] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49859 [id="node_49859" labelType="html" label="MapPartitionsRDD [49859] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49860 [id="node_49860" labelType="html" label="MapPartitionsRDD [49860] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130024 { id="cluster_130024"; isCluster="true"; label="DeserializeToObject"; 49861 [id="node_49861" labelType="html" label="MapPartitionsRDD [49861] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130081 { id="cluster_130081"; isCluster="true"; label="mapPartitions"; 49863 [id="node_49863" labelType="html" label="MapPartitionsRDD [49863] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49853->49854; 49854->49855; 49855->49856; 49856->49857; 49857->49858; 49858->49859; 49859->49860; 49860->49861; 49861->49862; 49862->49863; }