digraph G { id="graph_114638"; subgraph graph_stage_114638 { id="graph_stage_114638"; isCluster="true"; label="Stage 114638"; 54693 [id="node_54693" labelType="html" label="SQLExecutionRDD [54693] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_141954 { id="cluster_141954"; isCluster="true"; label="Exchange"; 54684 [id="node_54684" labelType="html" label="ShuffledRowRDD [54684] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141949 { id="cluster_141949"; isCluster="true"; label="WholeStageCodegen (6)"; 54685 [id="node_54685" labelType="html" label="MapPartitionsRDD [54685] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141948 { id="cluster_141948"; isCluster="true"; label="SortAggregate"; 54686 [id="node_54686" labelType="html" label="MapPartitionsRDD [54686] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141947 { id="cluster_141947"; isCluster="true"; label="InMemoryTableScan"; 54687 [id="node_54687" labelType="html" label="MapPartitionsRDD [54687] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54688 [id="node_54688" labelType="html" label="SortAggregate(key=[demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L, demandStream#1097953], functions=[first(kpis#1097981, false)], output=[shardId#1011815, worklistShardItemId#1011816L, qty#1097972, demandChannel#1097952, demandStream#1097953, kpis#1098114])\n+- *(6) Sort [demandChannel#1097952 ASC NULLS FIRST, shardId#1011815 ASC NULLS FIRST, qty#1097972 ASC NULLS FIRST, worklistShardItemId#1011816L ASC NULLS FIRST, demandStream#1097953 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L, demandStream#1097953, 37), ENSURE_REQUIREMENTS, [plan_id=1698352]\n +- SortAggregate(key=[demandChannel#1097952, shardId#1011815, knownfloatingpointnormalized(normalizenanandzero(qty#1097972)) AS qty#1097972, worklistShardItemId#1011816L, demandStream#1097953], functions=[partial_first(kpis#1097981, false)], output=[demandChannel#1097952, shardId#1011815, qty#1097972, worklistShardItemId#1011816L,... [54688] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54689 [id="node_54689" labelType="html" label="MapPartitionsRDD [54689] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54690 [id="node_54690" labelType="html" label="MapPartitionsRDD [54690] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 54691 [id="node_54691" labelType="html" label="MapPartitionsRDD [54691] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_141946 { id="cluster_141946"; isCluster="true"; label="DeserializeToObject"; 54692 [id="node_54692" labelType="html" label="MapPartitionsRDD [54692] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_142003 { id="cluster_142003"; isCluster="true"; label="mapPartitions"; 54694 [id="node_54694" labelType="html" label="MapPartitionsRDD [54694] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 54684->54685; 54685->54686; 54686->54687; 54687->54688; 54688->54689; 54689->54690; 54690->54691; 54691->54692; 54692->54693; 54693->54694; }