digraph G { id="graph_113943"; subgraph graph_stage_113943 { id="graph_stage_113943"; isCluster="true"; label="Stage 113943"; 54435 [id="node_54435" labelType="html" label="SQLExecutionRDD [54435] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_140823 { id="cluster_140823"; isCluster="true"; label="repartition"; 54187 [id="node_54187" labelType="html" label="ShuffledRDD [54187] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54188 [id="node_54188" labelType="html" label="CoalescedRDD [54188] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54189 [id="node_54189" labelType="html" label="MapPartitionsRDD [54189] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141334 { id="cluster_141334"; isCluster="true"; label="Exchange"; 54420 [id="node_54420" labelType="html" label="ShuffledRowRDD [54420] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141328 { id="cluster_141328"; isCluster="true"; label="WholeStageCodegen (6)"; 54421 [id="node_54421" labelType="html" label="MapPartitionsRDD [54421] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141327 { id="cluster_141327"; isCluster="true"; label="SortAggregate"; 54422 [id="node_54422" labelType="html" label="MapPartitionsRDD [54422] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141326 { id="cluster_141326"; isCluster="true"; label="InMemoryTableScan"; 54423 [id="node_54423" labelType="html" label="MapPartitionsRDD [54423] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54424 [id="node_54424" labelType="html" label="SortAggregate(key=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[first(kpis#1092423, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1092414, demandChannel#1092394, demandStream#1092395, kpis#1092556])\n+- *(6) Sort [demandChannel#1092394 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1092414 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1092395 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L, demandStream#1092395, 37), ENSURE_REQUIREMENTS, [plan_id=1696762]\n +- SortAggregate(key=[demandChannel#1092394, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1092414)) AS qty#1092414, worklistShardItemId#1011816L, demandStream#1092395], functions=[partial_first(kpis#1092423, false)], output=[demandChannel#1092394, shardId#1011815, qty#1092414, worklistShardItemId#1011816L,... [54424] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141420 { id="cluster_141420"; isCluster="true"; label="InMemoryTableScan"; 54431 [id="node_54431" labelType="html" label="MapPartitionsRDD [54431] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54432 [id="node_54432" labelType="html" label="MapPartitionsRDD [54432] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54433 [id="node_54433" labelType="html" label="MapPartitionsRDD [54433] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141419 { id="cluster_141419"; isCluster="true"; label="DeserializeToObject"; 54434 [id="node_54434" labelType="html" label="MapPartitionsRDD [54434] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141421 { id="cluster_141421"; isCluster="true"; label="mapPartitions"; 54436 [id="node_54436" labelType="html" label="MapPartitionsRDD [54436] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141441 { id="cluster_141441"; isCluster="true"; label="union"; 54445 [id="node_54445" labelType="html" label="UnionRDD [54445] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141442 { id="cluster_141442"; isCluster="true"; label="filter"; 54446 [id="node_54446" labelType="html" label="MapPartitionsRDD [54446] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141443 { id="cluster_141443"; isCluster="true"; label="distinct"; 54447 [id="node_54447" labelType="html" label="MapPartitionsRDD [54447] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54187->54188; 54188->54189; 54420->54421; 54421->54422; 54422->54423; 54423->54424; 54424->54431; 54431->54432; 54432->54433; 54433->54434; 54434->54435; 54435->54436; 54189->54445; 54436->54445; 54445->54446; 54446->54447; }