digraph G { id="graph_98706"; subgraph graph_stage_98706 { id="graph_stage_98706"; isCluster="true"; label="Stage 98706"; 44887 [id="node_44887" labelType="html" label="SQLExecutionRDD [44887] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_115903 { id="cluster_115903"; isCluster="true"; label="repartition"; 44639 [id="node_44639" labelType="html" label="ShuffledRDD [44639] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44640 [id="node_44640" labelType="html" label="CoalescedRDD [44640] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44641 [id="node_44641" labelType="html" label="MapPartitionsRDD [44641] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116413 { id="cluster_116413"; isCluster="true"; label="Exchange"; 44872 [id="node_44872" labelType="html" label="ShuffledRowRDD [44872] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116408 { id="cluster_116408"; isCluster="true"; label="WholeStageCodegen (6)"; 44873 [id="node_44873" labelType="html" label="MapPartitionsRDD [44873] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116407 { id="cluster_116407"; isCluster="true"; label="SortAggregate"; 44874 [id="node_44874" labelType="html" label="MapPartitionsRDD [44874] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116406 { id="cluster_116406"; isCluster="true"; label="InMemoryTableScan"; 44875 [id="node_44875" labelType="html" label="MapPartitionsRDD [44875] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44876 [id="node_44876" labelType="html" label="SortAggregate(key=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[first(kpis#902238, false)], output=[shardId#815740, worklistShardItemId#815741L, qty#902229, demandChannel#902209, demandStream#902210, kpis#902371])\n+- *(6) Sort [demandChannel#902209 ASC NULLS FIRST, shardId#815740 ASC NULLS FIRST, qty#902229 ASC NULLS FIRST, worklistShardItemId#815741L ASC NULLS FIRST, demandStream#902210 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, 37), ENSURE_REQUIREMENTS, [plan_id=1393658]\n +- SortAggregate(key=[demandChannel#902209, shardId#815740, knownfloatingpointnormalized(normalizenanandzero(qty#902229)) AS qty#902229, worklistShardItemId#815741L, demandStream#902210], functions=[partial_first(kpis#902238, false)], output=[demandChannel#902209, shardId#815740, qty#902229, worklistShardItemId#815741L, demandStream#902210, first#90244... [44876] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116500 { id="cluster_116500"; isCluster="true"; label="InMemoryTableScan"; 44883 [id="node_44883" labelType="html" label="MapPartitionsRDD [44883] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44884 [id="node_44884" labelType="html" label="MapPartitionsRDD [44884] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44885 [id="node_44885" labelType="html" label="MapPartitionsRDD [44885] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116499 { id="cluster_116499"; isCluster="true"; label="DeserializeToObject"; 44886 [id="node_44886" labelType="html" label="MapPartitionsRDD [44886] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116501 { id="cluster_116501"; isCluster="true"; label="mapPartitions"; 44888 [id="node_44888" labelType="html" label="MapPartitionsRDD [44888] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116521 { id="cluster_116521"; isCluster="true"; label="union"; 44897 [id="node_44897" labelType="html" label="UnionRDD [44897] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116522 { id="cluster_116522"; isCluster="true"; label="filter"; 44898 [id="node_44898" labelType="html" label="MapPartitionsRDD [44898] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_116523 { id="cluster_116523"; isCluster="true"; label="distinct"; 44899 [id="node_44899" labelType="html" label="MapPartitionsRDD [44899] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44639->44640; 44640->44641; 44872->44873; 44873->44874; 44874->44875; 44875->44876; 44876->44883; 44883->44884; 44884->44885; 44885->44886; 44886->44887; 44887->44888; 44641->44897; 44888->44897; 44897->44898; 44898->44899; }