digraph G { id="graph_333295"; subgraph graph_stage_333295 { id="graph_stage_333295"; isCluster="true"; label="Stage 333295"; 152056 [id="node_152056" labelType="html" label="SQLExecutionRDD [152056] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379947 { id="cluster_379947"; isCluster="true"; label="Exchange"; 151944 [id="node_151944" labelType="html" label="ShuffledRowRDD [151944] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379946 { id="cluster_379946"; isCluster="true"; label="InMemoryTableScan"; 151945 [id="node_151945" labelType="html" label="MapPartitionsRDD [151945] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151946 [id="node_151946" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3572038L, 30), REPARTITION_BY_NUM, [plan_id=1022926]\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=1022922]\n +- HashAggregate(keys=[demandChannel#3572041, shardId#3572037, knownfloatingpointnormalized(transform(kpis#3572043, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575089)) null else named_struct(label, lambda arg#3575089.label, dateTime, lambda arg#3575089.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575089.value)))), lambda ... [151946] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380179 { id="cluster_380179"; isCluster="true"; label="repartition"; 152037 [id="node_152037" labelType="html" label="ShuffledRDD [152037] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 152038 [id="node_152038" labelType="html" label="CoalescedRDD [152038] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 152039 [id="node_152039" labelType="html" label="MapPartitionsRDD [152039] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380212 { id="cluster_380212"; isCluster="true"; label="InMemoryTableScan"; 152052 [id="node_152052" labelType="html" label="MapPartitionsRDD [152052] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 152053 [id="node_152053" labelType="html" label="MapPartitionsRDD [152053] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 152054 [id="node_152054" labelType="html" label="MapPartitionsRDD [152054] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380211 { id="cluster_380211"; isCluster="true"; label="DeserializeToObject"; 152055 [id="node_152055" labelType="html" label="MapPartitionsRDD [152055] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380213 { id="cluster_380213"; isCluster="true"; label="mapPartitions"; 152057 [id="node_152057" labelType="html" label="MapPartitionsRDD [152057] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380214 { id="cluster_380214"; isCluster="true"; label="union"; 152058 [id="node_152058" labelType="html" label="UnionRDD [152058] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380215 { id="cluster_380215"; isCluster="true"; label="keyBy"; 152059 [id="node_152059" labelType="html" label="MapPartitionsRDD [152059] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151944->151945; 151945->151946; 152037->152038; 152038->152039; 151946->152052; 152052->152053; 152053->152054; 152054->152055; 152055->152056; 152056->152057; 152039->152058; 152057->152058; 152058->152059; }