digraph G { id="graph_99554"; subgraph graph_stage_99554 { id="graph_stage_99554"; isCluster="true"; label="Stage 99554"; 45994 [id="node_45994" labelType="html" label="SQLExecutionRDD [45994] [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}"]; 45990 [id="node_45990" labelType="html" label="MapPartitionsRDD [45990] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45991 [id="node_45991" labelType="html" label="MapPartitionsRDD [45991] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 45992 [id="node_45992" labelType="html" label="MapPartitionsRDD [45992] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119483 { id="cluster_119483"; isCluster="true"; label="DeserializeToObject"; 45993 [id="node_45993" labelType="html" label="MapPartitionsRDD [45993] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119540 { id="cluster_119540"; isCluster="true"; label="mapPartitions"; 45995 [id="node_45995" labelType="html" label="MapPartitionsRDD [45995] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45985->45986; 45986->45987; 45987->45988; 45988->45989; 45989->45990; 45990->45991; 45991->45992; 45992->45993; 45993->45994; 45994->45995; }