digraph G { id="graph_90542"; subgraph graph_stage_90542 { id="graph_stage_90542"; isCluster="true"; label="Stage 90542"; 41955 [id="node_41955" labelType="html" label="SQLExecutionRDD [41955] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_108991 { id="cluster_108991"; isCluster="true"; label="repartition"; 41703 [id="node_41703" labelType="html" label="ShuffledRDD [41703] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41704 [id="node_41704" labelType="html" label="CoalescedRDD [41704] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41705 [id="node_41705" labelType="html" label="MapPartitionsRDD [41705] [Cached] [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}"]; } subgraph cluster_109599 { id="cluster_109599"; isCluster="true"; label="InMemoryTableScan"; 41951 [id="node_41951" labelType="html" label="MapPartitionsRDD [41951] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41952 [id="node_41952" labelType="html" label="MapPartitionsRDD [41952] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 41953 [id="node_41953" labelType="html" label="MapPartitionsRDD [41953] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109598 { id="cluster_109598"; isCluster="true"; label="DeserializeToObject"; 41954 [id="node_41954" labelType="html" label="MapPartitionsRDD [41954] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109600 { id="cluster_109600"; isCluster="true"; label="mapPartitions"; 41956 [id="node_41956" labelType="html" label="MapPartitionsRDD [41956] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109620 { id="cluster_109620"; isCluster="true"; label="union"; 41965 [id="node_41965" labelType="html" label="UnionRDD [41965] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109621 { id="cluster_109621"; isCluster="true"; label="filter"; 41966 [id="node_41966" labelType="html" label="MapPartitionsRDD [41966] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109622 { id="cluster_109622"; isCluster="true"; label="distinct"; 41967 [id="node_41967" labelType="html" label="MapPartitionsRDD [41967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 41703->41704; 41704->41705; 41940->41941; 41941->41942; 41942->41943; 41943->41944; 41944->41951; 41951->41952; 41952->41953; 41953->41954; 41954->41955; 41955->41956; 41705->41965; 41956->41965; 41965->41966; 41966->41967; }