digraph G { id="graph_1118"; subgraph graph_stage_1118 { id="graph_stage_1118"; isCluster="true"; label="Stage 1118"; 1658 [id="node_1658" labelType="html" label="SQLExecutionRDD [1658] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_3831 { id="cluster_3831"; isCluster="true"; label="map"; 1447 [id="node_1447" labelType="html" label="MapPartitionsRDD [1447] [Cached] [Indeterminate]<br>map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_3832 { id="cluster_3832"; isCluster="true"; label="checkpoint"; 1448 [id="node_1448" labelType="html" label="LocalCheckpointRDD [1448]<br>count at CachePortImpl.java:132}"]; } subgraph cluster_4225 { id="cluster_4225"; isCluster="true"; label="Exchange"; 1643 [id="node_1643" labelType="html" label="ShuffledRowRDD [1643] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4222 { id="cluster_4222"; isCluster="true"; label="WholeStageCodegen (8)"; 1644 [id="node_1644" labelType="html" label="MapPartitionsRDD [1644] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4221 { id="cluster_4221"; isCluster="true"; label="SortAggregate"; 1645 [id="node_1645" labelType="html" label="MapPartitionsRDD [1645] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4220 { id="cluster_4220"; isCluster="true"; label="InMemoryTableScan"; 1646 [id="node_1646" labelType="html" label="MapPartitionsRDD [1646] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1647 [id="node_1647" labelType="html" label="SortAggregate(key=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[first(kpis#27292, false)], output=[shardId#445, worklistShardItemId#446L, qty#27283, demandChannel#27263, demandStream#27264, kpis#27425])\n+- *(8) Sort [demandChannel#27263 ASC NULLS FIRST, shardId#445 ASC NULLS FIRST, qty#27283 ASC NULLS FIRST, worklistShardItemId#446L ASC NULLS FIRST, demandStream#27264 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, 37), ENSURE_REQUIREMENTS, [plan_id=118557]\n +- SortAggregate(key=[demandChannel#27263, shardId#445, knownfloatingpointnormalized(normalizenanandzero(qty#27283)) AS qty#27283, worklistShardItemId#446L, demandStream#27264], functions=[partial_first(kpis#27292, false)], output=[demandChannel#27263, shardId#445, qty#27283, worklistShardItemId#446L, demandStream#27264, first#27501, valueSet#27502])\n +- *(7) Sort [demandChannel#272... [1647] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4328 { id="cluster_4328"; isCluster="true"; label="InMemoryTableScan"; 1654 [id="node_1654" labelType="html" label="MapPartitionsRDD [1654] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1655 [id="node_1655" labelType="html" label="MapPartitionsRDD [1655] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 1656 [id="node_1656" labelType="html" label="MapPartitionsRDD [1656] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4327 { id="cluster_4327"; isCluster="true"; label="DeserializeToObject"; 1657 [id="node_1657" labelType="html" label="MapPartitionsRDD [1657] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4329 { id="cluster_4329"; isCluster="true"; label="mapPartitions"; 1659 [id="node_1659" labelType="html" label="MapPartitionsRDD [1659] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4349 { id="cluster_4349"; isCluster="true"; label="union"; 1668 [id="node_1668" labelType="html" label="UnionRDD [1668] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4350 { id="cluster_4350"; isCluster="true"; label="filter"; 1669 [id="node_1669" labelType="html" label="MapPartitionsRDD [1669] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_4351 { id="cluster_4351"; isCluster="true"; label="distinct"; 1670 [id="node_1670" labelType="html" label="MapPartitionsRDD [1670] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1448->1447; 1643->1644; 1644->1645; 1645->1646; 1646->1647; 1647->1654; 1654->1655; 1655->1656; 1656->1657; 1657->1658; 1658->1659; 1447->1668; 1659->1668; 1668->1669; 1669->1670; }