digraph G { id="graph_118956"; subgraph graph_stage_118956 { id="graph_stage_118956"; isCluster="true"; label="Stage 118956"; 57664 [id="node_57664" labelType="html" label="SQLExecutionRDD [57664] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_149413 { id="cluster_149413"; isCluster="true"; label="Exchange"; 57655 [id="node_57655" labelType="html" label="ShuffledRowRDD [57655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149408 { id="cluster_149408"; isCluster="true"; label="WholeStageCodegen (6)"; 57656 [id="node_57656" labelType="html" label="MapPartitionsRDD [57656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149407 { id="cluster_149407"; isCluster="true"; label="SortAggregate"; 57657 [id="node_57657" labelType="html" label="MapPartitionsRDD [57657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149406 { id="cluster_149406"; isCluster="true"; label="InMemoryTableScan"; 57658 [id="node_57658" labelType="html" label="MapPartitionsRDD [57658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57659 [id="node_57659" labelType="html" label="SortAggregate(key=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[first(kpis#1159034, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1159025, demandChannel#1159005, demandStream#1159006, kpis#1159167])\n+- *(6) Sort [demandChannel#1159005 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1159025 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1159006 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006, 37), ENSURE_REQUIREMENTS, [plan_id=1764206]\n +- SortAggregate(key=[demandChannel#1159005, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1159025)) AS qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[partial_first(kpis#1159034, false)], output=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L,... [57659] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57660 [id="node_57660" labelType="html" label="MapPartitionsRDD [57660] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57661 [id="node_57661" labelType="html" label="MapPartitionsRDD [57661] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 57662 [id="node_57662" labelType="html" label="MapPartitionsRDD [57662] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149405 { id="cluster_149405"; isCluster="true"; label="DeserializeToObject"; 57663 [id="node_57663" labelType="html" label="MapPartitionsRDD [57663] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149462 { id="cluster_149462"; isCluster="true"; label="mapPartitions"; 57665 [id="node_57665" labelType="html" label="MapPartitionsRDD [57665] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57655->57656; 57656->57657; 57657->57658; 57658->57659; 57659->57660; 57660->57661; 57661->57662; 57662->57663; 57663->57664; 57664->57665; }