digraph G { id="graph_1032526"; subgraph graph_stage_1032526 { id="graph_stage_1032526"; isCluster="true"; label="Stage 1032526"; 434089 [id="node_434089" labelType="html" label="SQLExecutionRDD [434089] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1087487 { id="cluster_1087487"; isCluster="true"; label="repartition"; 434061 [id="node_434061" labelType="html" label="ShuffledRDD [434061] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; 434062 [id="node_434062" labelType="html" label="CoalescedRDD [434062] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; 434063 [id="node_434063" labelType="html" label="MapPartitionsRDD [434063] [Cached] [Indeterminate]<br>repartition at KpiCurveCacheImpl.java:98}"]; } subgraph cluster_1087500 { id="cluster_1087500"; isCluster="true"; label="Exchange"; 434074 [id="node_434074" labelType="html" label="ShuffledRowRDD [434074] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087499 { id="cluster_1087499"; isCluster="true"; label="InMemoryTableScan"; 434075 [id="node_434075" labelType="html" label="MapPartitionsRDD [434075] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 434076 [id="node_434076" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#9675734L, 30), REPARTITION_BY_NUM, [plan_id=3017737]\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=3017733]\n +- HashAggregate(keys=[demandChannel#9675737, shardId#9675733, knownfloatingpointnormalized(transform(kpis#9675739, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#10205592)) null else named_struct(label, lambda arg#10205592.label, dateTime, lambda arg#10205592.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#10205592.value)))), lam... [434076] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087542 { id="cluster_1087542"; isCluster="true"; label="InMemoryTableScan"; 434085 [id="node_434085" labelType="html" label="MapPartitionsRDD [434085] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 434086 [id="node_434086" labelType="html" label="MapPartitionsRDD [434086] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 434087 [id="node_434087" labelType="html" label="MapPartitionsRDD [434087] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087541 { id="cluster_1087541"; isCluster="true"; label="DeserializeToObject"; 434088 [id="node_434088" labelType="html" label="MapPartitionsRDD [434088] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087543 { id="cluster_1087543"; isCluster="true"; label="mapPartitions"; 434090 [id="node_434090" labelType="html" label="MapPartitionsRDD [434090] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087544 { id="cluster_1087544"; isCluster="true"; label="union"; 434091 [id="node_434091" labelType="html" label="UnionRDD [434091] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087545 { id="cluster_1087545"; isCluster="true"; label="keyBy"; 434092 [id="node_434092" labelType="html" label="MapPartitionsRDD [434092] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 434061->434062; 434062->434063; 434074->434075; 434075->434076; 434076->434085; 434085->434086; 434086->434087; 434087->434088; 434088->434089; 434089->434090; 434063->434091; 434090->434091; 434091->434092; }