digraph G { id="graph_117116"; subgraph graph_stage_117116 { id="graph_stage_117116"; isCluster="true"; label="Stage 117116"; 56614 [id="node_56614" labelType="html" label="SQLExecutionRDD [56614] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_146435 { id="cluster_146435"; isCluster="true"; label="map"; 56367 [id="node_56367" labelType="html" label="MapPartitionsRDD [56367] [Cached] [Indeterminate]<br>map at PeriodicAsyncRDDCheckpointWriterImpl.java:207}"]; } subgraph cluster_146452 { id="cluster_146452"; isCluster="true"; label="checkpoint"; 56376 [id="node_56376" labelType="html" label="LocalCheckpointRDD [56376]<br>count at CachePortImpl.java:132}"]; } subgraph cluster_146930 { id="cluster_146930"; isCluster="true"; label="Exchange"; 56599 [id="node_56599" labelType="html" label="ShuffledRowRDD [56599] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146924 { id="cluster_146924"; isCluster="true"; label="WholeStageCodegen (6)"; 56600 [id="node_56600" labelType="html" label="MapPartitionsRDD [56600] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146923 { id="cluster_146923"; isCluster="true"; label="SortAggregate"; 56601 [id="node_56601" labelType="html" label="MapPartitionsRDD [56601] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146922 { id="cluster_146922"; isCluster="true"; label="InMemoryTableScan"; 56602 [id="node_56602" labelType="html" label="MapPartitionsRDD [56602] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56603 [id="node_56603" labelType="html" label="SortAggregate(key=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[first(kpis#1136802, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1136793, demandChannel#1136773, demandStream#1136774, kpis#1136935])\n+- *(6) Sort [demandChannel#1136773 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1136793 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1136774 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L, demandStream#1136774, 37), ENSURE_REQUIREMENTS, [plan_id=1757887]\n +- SortAggregate(key=[demandChannel#1136773, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1136793)) AS qty#1136793, worklistShardItemId#1100458L, demandStream#1136774], functions=[partial_first(kpis#1136802, false)], output=[demandChannel#1136773, shardId#1100457, qty#1136793, worklistShardItemId#1100458L,... [56603] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147016 { id="cluster_147016"; isCluster="true"; label="InMemoryTableScan"; 56610 [id="node_56610" labelType="html" label="MapPartitionsRDD [56610] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56611 [id="node_56611" labelType="html" label="MapPartitionsRDD [56611] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56612 [id="node_56612" labelType="html" label="MapPartitionsRDD [56612] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147015 { id="cluster_147015"; isCluster="true"; label="DeserializeToObject"; 56613 [id="node_56613" labelType="html" label="MapPartitionsRDD [56613] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147017 { id="cluster_147017"; isCluster="true"; label="mapPartitions"; 56615 [id="node_56615" labelType="html" label="MapPartitionsRDD [56615] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147037 { id="cluster_147037"; isCluster="true"; label="union"; 56624 [id="node_56624" labelType="html" label="UnionRDD [56624] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147038 { id="cluster_147038"; isCluster="true"; label="filter"; 56625 [id="node_56625" labelType="html" label="MapPartitionsRDD [56625] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_147039 { id="cluster_147039"; isCluster="true"; label="distinct"; 56626 [id="node_56626" labelType="html" label="MapPartitionsRDD [56626] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56376->56367; 56599->56600; 56600->56601; 56601->56602; 56602->56603; 56603->56610; 56610->56611; 56611->56612; 56612->56613; 56613->56614; 56614->56615; 56367->56624; 56615->56624; 56624->56625; 56625->56626; }