digraph G { id="graph_102623"; subgraph graph_stage_102623 { id="graph_stage_102623"; isCluster="true"; label="Stage 102623"; 49334 [id="node_49334" labelType="html" label="SQLExecutionRDD [49334] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_128790 { id="cluster_128790"; isCluster="true"; label="Exchange"; 49325 [id="node_49325" labelType="html" label="ShuffledRowRDD [49325] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128785 { id="cluster_128785"; isCluster="true"; label="WholeStageCodegen (6)"; 49326 [id="node_49326" labelType="html" label="MapPartitionsRDD [49326] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128784 { id="cluster_128784"; isCluster="true"; label="SortAggregate"; 49327 [id="node_49327" labelType="html" label="MapPartitionsRDD [49327] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128783 { id="cluster_128783"; isCluster="true"; label="InMemoryTableScan"; 49328 [id="node_49328" labelType="html" label="MapPartitionsRDD [49328] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49329 [id="node_49329" labelType="html" label="SortAggregate(key=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[first(kpis#987107, false)], output=[shardId#943631, worklistShardItemId#943632L, qty#987098, demandChannel#987078, demandStream#987079, kpis#987240])\n+- *(6) Sort [demandChannel#987078 ASC NULLS FIRST, shardId#943631 ASC NULLS FIRST, qty#987098 ASC NULLS FIRST, worklistShardItemId#943632L ASC NULLS FIRST, demandStream#987079 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, 37), ENSURE_REQUIREMENTS, [plan_id=1626640]\n +- SortAggregate(key=[demandChannel#987078, shardId#943631, knownfloatingpointnormalized(normalizenanandzero(qty#987098)) AS qty#987098, worklistShardItemId#943632L, demandStream#987079], functions=[partial_first(kpis#987107, false)], output=[demandChannel#987078, shardId#943631, qty#987098, worklistShardItemId#943632L, demandStream#987079, first#98731... [49329] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49330 [id="node_49330" labelType="html" label="MapPartitionsRDD [49330] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49331 [id="node_49331" labelType="html" label="MapPartitionsRDD [49331] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49332 [id="node_49332" labelType="html" label="MapPartitionsRDD [49332] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128782 { id="cluster_128782"; isCluster="true"; label="DeserializeToObject"; 49333 [id="node_49333" labelType="html" label="MapPartitionsRDD [49333] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128839 { id="cluster_128839"; isCluster="true"; label="mapPartitions"; 49335 [id="node_49335" labelType="html" label="MapPartitionsRDD [49335] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49325->49326; 49326->49327; 49327->49328; 49328->49329; 49329->49330; 49330->49331; 49331->49332; 49332->49333; 49333->49334; 49334->49335; }