digraph G { id="graph_332376"; subgraph graph_stage_332376 { id="graph_stage_332376"; isCluster="true"; label="Stage 332376"; 151838 [id="node_151838" labelType="html" label="SQLExecutionRDD [151838] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379435 { id="cluster_379435"; isCluster="true"; label="Exchange"; 151691 [id="node_151691" labelType="html" label="ShuffledRowRDD [151691] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379434 { id="cluster_379434"; isCluster="true"; label="InMemoryTableScan"; 151692 [id="node_151692" labelType="html" label="MapPartitionsRDD [151692] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151693 [id="node_151693" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1021857]\n+- *(2) HashAggregate(keys=[demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719], functions=[], output=[shardId#3571714, worklistShardItemId#3571715L, version#3571716, qty#3571717, demandChannel#3571718, demandStream#3571719, kpis#3571720])\n +- Exchange hashpartitioning(demandChannel#3571718, shardId#3571714, kpis#3571720, version#3571716, qty#3571717, worklistShardItemId#3571715L, demandStream#3571719, 30), ENSURE_REQUIREMENTS, [plan_id=1021853]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3572123)) null else named_struct(label, lambda arg#3572123.label, dateTime, lambda arg#3572123.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3572123.value)))), lambda ... [151693] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379570 { id="cluster_379570"; isCluster="true"; label="repartition"; 151749 [id="node_151749" labelType="html" label="ShuffledRDD [151749] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151750 [id="node_151750" labelType="html" label="CoalescedRDD [151750] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151751 [id="node_151751" labelType="html" label="MapPartitionsRDD [151751] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379738 { id="cluster_379738"; isCluster="true"; label="InMemoryTableScan"; 151834 [id="node_151834" labelType="html" label="MapPartitionsRDD [151834] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151835 [id="node_151835" labelType="html" label="MapPartitionsRDD [151835] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 151836 [id="node_151836" labelType="html" label="MapPartitionsRDD [151836] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379737 { id="cluster_379737"; isCluster="true"; label="DeserializeToObject"; 151837 [id="node_151837" labelType="html" label="MapPartitionsRDD [151837] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379739 { id="cluster_379739"; isCluster="true"; label="mapPartitions"; 151839 [id="node_151839" labelType="html" label="MapPartitionsRDD [151839] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379740 { id="cluster_379740"; isCluster="true"; label="union"; 151840 [id="node_151840" labelType="html" label="UnionRDD [151840] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_379741 { id="cluster_379741"; isCluster="true"; label="keyBy"; 151841 [id="node_151841" labelType="html" label="MapPartitionsRDD [151841] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151691->151692; 151692->151693; 151749->151750; 151750->151751; 151693->151834; 151834->151835; 151835->151836; 151836->151837; 151837->151838; 151838->151839; 151751->151840; 151839->151840; 151840->151841; }