digraph G { id="graph_120044"; subgraph graph_stage_120044 { id="graph_stage_120044"; isCluster="true"; label="Stage 120044"; 57934 [id="node_57934" labelType="html" label="SQLExecutionRDD [57934] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_149524 { id="cluster_149524"; isCluster="true"; label="repartition"; 57686 [id="node_57686" labelType="html" label="ShuffledRDD [57686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57687 [id="node_57687" labelType="html" label="CoalescedRDD [57687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57688 [id="node_57688" labelType="html" label="MapPartitionsRDD [57688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150035 { id="cluster_150035"; isCluster="true"; label="Exchange"; 57919 [id="node_57919" labelType="html" label="ShuffledRowRDD [57919] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150029 { id="cluster_150029"; isCluster="true"; label="WholeStageCodegen (6)"; 57920 [id="node_57920" labelType="html" label="MapPartitionsRDD [57920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150028 { id="cluster_150028"; isCluster="true"; label="SortAggregate"; 57921 [id="node_57921" labelType="html" label="MapPartitionsRDD [57921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150027 { id="cluster_150027"; isCluster="true"; label="InMemoryTableScan"; 57922 [id="node_57922" labelType="html" label="MapPartitionsRDD [57922] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57923 [id="node_57923" labelType="html" label="SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])\n+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]\n +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,... [57923] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150121 { id="cluster_150121"; isCluster="true"; label="InMemoryTableScan"; 57930 [id="node_57930" labelType="html" label="MapPartitionsRDD [57930] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57931 [id="node_57931" labelType="html" label="MapPartitionsRDD [57931] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57932 [id="node_57932" labelType="html" label="MapPartitionsRDD [57932] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150120 { id="cluster_150120"; isCluster="true"; label="DeserializeToObject"; 57933 [id="node_57933" labelType="html" label="MapPartitionsRDD [57933] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150122 { id="cluster_150122"; isCluster="true"; label="mapPartitions"; 57935 [id="node_57935" labelType="html" label="MapPartitionsRDD [57935] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150142 { id="cluster_150142"; isCluster="true"; label="union"; 57944 [id="node_57944" labelType="html" label="UnionRDD [57944] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150143 { id="cluster_150143"; isCluster="true"; label="filter"; 57945 [id="node_57945" labelType="html" label="MapPartitionsRDD [57945] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150144 { id="cluster_150144"; isCluster="true"; label="distinct"; 57946 [id="node_57946" labelType="html" label="MapPartitionsRDD [57946] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57686->57687; 57687->57688; 57919->57920; 57920->57921; 57921->57922; 57922->57923; 57923->57930; 57930->57931; 57931->57932; 57932->57933; 57933->57934; 57934->57935; 57688->57944; 57935->57944; 57944->57945; 57945->57946; }