digraph G { id="graph_103704"; subgraph graph_stage_103704 { id="graph_stage_103704"; isCluster="true"; label="Stage 103704"; 49868 [id="node_49868" labelType="html" label="SQLExecutionRDD [49868] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_129522 { id="cluster_129522"; isCluster="true"; label="repartition"; 49620 [id="node_49620" labelType="html" label="ShuffledRDD [49620] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49621 [id="node_49621" labelType="html" label="CoalescedRDD [49621] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49622 [id="node_49622" labelType="html" label="MapPartitionsRDD [49622] [Cached] [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}"]; } subgraph cluster_130119 { id="cluster_130119"; isCluster="true"; label="InMemoryTableScan"; 49864 [id="node_49864" labelType="html" label="MapPartitionsRDD [49864] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49865 [id="node_49865" labelType="html" label="MapPartitionsRDD [49865] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 49866 [id="node_49866" labelType="html" label="MapPartitionsRDD [49866] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130118 { id="cluster_130118"; isCluster="true"; label="DeserializeToObject"; 49867 [id="node_49867" labelType="html" label="MapPartitionsRDD [49867] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130120 { id="cluster_130120"; isCluster="true"; label="mapPartitions"; 49869 [id="node_49869" labelType="html" label="MapPartitionsRDD [49869] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130140 { id="cluster_130140"; isCluster="true"; label="union"; 49878 [id="node_49878" labelType="html" label="UnionRDD [49878] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130141 { id="cluster_130141"; isCluster="true"; label="filter"; 49879 [id="node_49879" labelType="html" label="MapPartitionsRDD [49879] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_130142 { id="cluster_130142"; isCluster="true"; label="distinct"; 49880 [id="node_49880" labelType="html" label="MapPartitionsRDD [49880] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49620->49621; 49621->49622; 49853->49854; 49854->49855; 49855->49856; 49856->49857; 49857->49864; 49864->49865; 49865->49866; 49866->49867; 49867->49868; 49868->49869; 49622->49878; 49869->49878; 49878->49879; 49879->49880; }