digraph G { id="graph_332041"; subgraph graph_stage_332041 { id="graph_stage_332041"; isCluster="true"; label="Stage 332041"; 151742 [id="node_151742" labelType="html" label="SQLExecutionRDD [151742] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379473 { id="cluster_379473"; isCluster="true"; label="repartition"; 151713 [id="node_151713" labelType="html" label="ShuffledRDD [151713] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151714 [id="node_151714" labelType="html" label="CoalescedRDD [151714] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151715 [id="node_151715" labelType="html" label="MapPartitionsRDD [151715] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379486 { id="cluster_379486"; isCluster="true"; label="Exchange"; 151726 [id="node_151726" labelType="html" label="ShuffledRowRDD [151726] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379485 { id="cluster_379485"; isCluster="true"; label="InMemoryTableScan"; 151727 [id="node_151727" labelType="html" label="MapPartitionsRDD [151727] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151728 [id="node_151728" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3572038L, 30), REPARTITION_BY_NUM, [plan_id=1021944]\n+- *(2) HashAggregate(keys=[demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042], functions=[], output=[shardId#3572037, worklistShardItemId#3572038L, version#3572039, qty#3572040, demandChannel#3572041, demandStream#3572042, kpis#3572043])\n +- Exchange hashpartitioning(demandChannel#3572041, shardId#3572037, kpis#3572043, version#3572039, qty#3572040, worklistShardItemId#3572038L, demandStream#3572042, 30), ENSURE_REQUIREMENTS, [plan_id=1021940]\n +- HashAggregate(keys=[demandChannel#3572041, shardId#3572037, knownfloatingpointnormalized(transform(kpis#3572043, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3572584)) null else named_struct(label, lambda arg#3572584.label, dateTime, lambda arg#3572584.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3572584.value)))), lambda ... [151728] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379556 { id="cluster_379556"; isCluster="true"; label="InMemoryTableScan"; 151738 [id="node_151738" labelType="html" label="MapPartitionsRDD [151738] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151739 [id="node_151739" labelType="html" label="MapPartitionsRDD [151739] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151740 [id="node_151740" labelType="html" label="MapPartitionsRDD [151740] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379555 { id="cluster_379555"; isCluster="true"; label="DeserializeToObject"; 151741 [id="node_151741" labelType="html" label="MapPartitionsRDD [151741] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379557 { id="cluster_379557"; isCluster="true"; label="mapPartitions"; 151743 [id="node_151743" labelType="html" label="MapPartitionsRDD [151743] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379558 { id="cluster_379558"; isCluster="true"; label="union"; 151744 [id="node_151744" labelType="html" label="UnionRDD [151744] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379559 { id="cluster_379559"; isCluster="true"; label="keyBy"; 151745 [id="node_151745" labelType="html" label="MapPartitionsRDD [151745] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151713->151714; 151714->151715; 151726->151727; 151727->151728; 151728->151738; 151738->151739; 151739->151740; 151740->151741; 151741->151742; 151742->151743; 151715->151744; 151743->151744; 151744->151745; }