digraph G { id="graph_99625"; subgraph graph_stage_99625 { id="graph_stage_99625"; isCluster="true"; label="Stage 99625"; 46000 [id="node_46000" labelType="html" label="SQLExecutionRDD [46000] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_118982 { id="cluster_118982"; isCluster="true"; label="repartition"; 45752 [id="node_45752" labelType="html" label="ShuffledRDD [45752] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45753 [id="node_45753" labelType="html" label="CoalescedRDD [45753] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45754 [id="node_45754" labelType="html" label="MapPartitionsRDD [45754] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119492 { id="cluster_119492"; isCluster="true"; label="Exchange"; 45985 [id="node_45985" labelType="html" label="ShuffledRowRDD [45985] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119486 { id="cluster_119486"; isCluster="true"; label="WholeStageCodegen (6)"; 45986 [id="node_45986" labelType="html" label="MapPartitionsRDD [45986] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119485 { id="cluster_119485"; isCluster="true"; label="SortAggregate"; 45987 [id="node_45987" labelType="html" label="MapPartitionsRDD [45987] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119484 { id="cluster_119484"; isCluster="true"; label="InMemoryTableScan"; 45988 [id="node_45988" labelType="html" label="MapPartitionsRDD [45988] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45989 [id="node_45989" labelType="html" label="SortAggregate(key=[demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453], functions=[first(kpis#924481, false)], output=[shardId#904714, worklistShardItemId#904715L, qty#924472, demandChannel#924452, demandStream#924453, kpis#924614])\n+- *(6) Sort [demandChannel#924452 ASC NULLS FIRST, shardId#904714 ASC NULLS FIRST, qty#924472 ASC NULLS FIRST, worklistShardItemId#904715L ASC NULLS FIRST, demandStream#924453 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453, 37), ENSURE_REQUIREMENTS, [plan_id=1450243]\n +- SortAggregate(key=[demandChannel#924452, shardId#904714, knownfloatingpointnormalized(normalizenanandzero(qty#924472)) AS qty#924472, worklistShardItemId#904715L, demandStream#924453], functions=[partial_first(kpis#924481, false)], output=[demandChannel#924452, shardId#904714, qty#924472, worklistShardItemId#904715L, demandStream#924453, first#92469... [45989] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119578 { id="cluster_119578"; isCluster="true"; label="InMemoryTableScan"; 45996 [id="node_45996" labelType="html" label="MapPartitionsRDD [45996] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45997 [id="node_45997" labelType="html" label="MapPartitionsRDD [45997] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45998 [id="node_45998" labelType="html" label="MapPartitionsRDD [45998] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119577 { id="cluster_119577"; isCluster="true"; label="DeserializeToObject"; 45999 [id="node_45999" labelType="html" label="MapPartitionsRDD [45999] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119579 { id="cluster_119579"; isCluster="true"; label="mapPartitions"; 46001 [id="node_46001" labelType="html" label="MapPartitionsRDD [46001] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119599 { id="cluster_119599"; isCluster="true"; label="union"; 46010 [id="node_46010" labelType="html" label="UnionRDD [46010] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119600 { id="cluster_119600"; isCluster="true"; label="filter"; 46011 [id="node_46011" labelType="html" label="MapPartitionsRDD [46011] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119601 { id="cluster_119601"; isCluster="true"; label="distinct"; 46012 [id="node_46012" labelType="html" label="MapPartitionsRDD [46012] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45752->45753; 45753->45754; 45985->45986; 45986->45987; 45987->45988; 45988->45989; 45989->45996; 45996->45997; 45997->45998; 45998->45999; 45999->46000; 46000->46001; 45754->46010; 46001->46010; 46010->46011; 46011->46012; }