digraph G { id="graph_1027560"; subgraph graph_stage_1027560 { id="graph_stage_1027560"; isCluster="true"; label="Stage 1027560"; 433234 [id="node_433234" labelType="html" label="SQLExecutionRDD [433234] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1085339 { id="cluster_1085339"; isCluster="true"; label="repartition"; 433198 [id="node_433198" labelType="html" label="ShuffledRDD [433198] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; 433199 [id="node_433199" labelType="html" label="CoalescedRDD [433199] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; 433200 [id="node_433200" labelType="html" label="MapPartitionsRDD [433200] [Cached] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1085352 { id="cluster_1085352"; isCluster="true"; label="Exchange"; 433211 [id="node_433211" labelType="html" label="ShuffledRowRDD [433211] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085351 { id="cluster_1085351"; isCluster="true"; label="InMemoryTableScan"; 433212 [id="node_433212" labelType="html" label="MapPartitionsRDD [433212] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 433213 [id="node_433213" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3012520]\n+- *(2) HashAggregate(keys=[demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738], functions=[], output=[shardId#9675733, worklistShardItemId#9675734L, version#9675735, qty#9675736, demandChannel#9675737, demandStream#9675738, kpis#9675739])\n +- Exchange hashpartitioning(demandChannel#9675737, shardId#9675733, kpis#9675739, version#9675735, qty#9675736, worklistShardItemId#9675734L, demandStream#9675738, 30), ENSURE_REQUIREMENTS, [plan_id=3012516]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10184534)) null else named_struct(label, lambda arg#10184534.label, dateTime, lambda arg#10184534.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10184534.value)))), lam... [433213] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085413 { id="cluster_1085413"; isCluster="true"; label="InMemoryTableScan"; 433230 [id="node_433230" labelType="html" label="MapPartitionsRDD [433230] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 433231 [id="node_433231" labelType="html" label="MapPartitionsRDD [433231] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 433232 [id="node_433232" labelType="html" label="MapPartitionsRDD [433232] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085412 { id="cluster_1085412"; isCluster="true"; label="DeserializeToObject"; 433233 [id="node_433233" labelType="html" label="MapPartitionsRDD [433233] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085414 { id="cluster_1085414"; isCluster="true"; label="mapPartitions"; 433235 [id="node_433235" labelType="html" label="MapPartitionsRDD [433235] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085415 { id="cluster_1085415"; isCluster="true"; label="union"; 433236 [id="node_433236" labelType="html" label="UnionRDD [433236] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1085416 { id="cluster_1085416"; isCluster="true"; label="keyBy"; 433237 [id="node_433237" labelType="html" label="MapPartitionsRDD [433237] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 433198->433199; 433199->433200; 433211->433212; 433212->433213; 433213->433230; 433230->433231; 433231->433232; 433232->433233; 433233->433234; 433234->433235; 433200->433236; 433235->433236; 433236->433237; }