digraph G { id="graph_118244"; subgraph graph_stage_118244 { id="graph_stage_118244"; isCluster="true"; label="Stage 118244"; 57400 [id="node_57400" labelType="html" label="SQLExecutionRDD [57400] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_148792 { id="cluster_148792"; isCluster="true"; label="Exchange"; 57391 [id="node_57391" labelType="html" label="ShuffledRowRDD [57391] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148787 { id="cluster_148787"; isCluster="true"; label="WholeStageCodegen (6)"; 57392 [id="node_57392" labelType="html" label="MapPartitionsRDD [57392] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148786 { id="cluster_148786"; isCluster="true"; label="SortAggregate"; 57393 [id="node_57393" labelType="html" label="MapPartitionsRDD [57393] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148785 { id="cluster_148785"; isCluster="true"; label="InMemoryTableScan"; 57394 [id="node_57394" labelType="html" label="MapPartitionsRDD [57394] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57395 [id="node_57395" labelType="html" label="SortAggregate(key=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[first(kpis#1153476, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1153467, demandChannel#1153447, demandStream#1153448, kpis#1153609])\n+- *(6) Sort [demandChannel#1153447 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1153467 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1153448 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448, 37), ENSURE_REQUIREMENTS, [plan_id=1762616]\n +- SortAggregate(key=[demandChannel#1153447, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1153467)) AS qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[partial_first(kpis#1153476, false)], output=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L,... [57395] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57396 [id="node_57396" labelType="html" label="MapPartitionsRDD [57396] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57397 [id="node_57397" labelType="html" label="MapPartitionsRDD [57397] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57398 [id="node_57398" labelType="html" label="MapPartitionsRDD [57398] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148784 { id="cluster_148784"; isCluster="true"; label="DeserializeToObject"; 57399 [id="node_57399" labelType="html" label="MapPartitionsRDD [57399] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148841 { id="cluster_148841"; isCluster="true"; label="mapPartitions"; 57401 [id="node_57401" labelType="html" label="MapPartitionsRDD [57401] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57391->57392; 57392->57393; 57393->57394; 57394->57395; 57395->57396; 57396->57397; 57397->57398; 57398->57399; 57399->57400; 57400->57401; }