digraph G { id="graph_333153"; subgraph graph_stage_333153 { id="graph_stage_333153"; isCluster="true"; label="Stage 333153"; 152030 [id="node_152030" labelType="html" label="SQLExecutionRDD [152030] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_379925 { id="cluster_379925"; isCluster="true"; label="repartition"; 151920 [id="node_151920" labelType="html" label="ShuffledRDD [151920] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151921 [id="node_151921" labelType="html" label="CoalescedRDD [151921] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 151922 [id="node_151922" labelType="html" label="MapPartitionsRDD [151922] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380095 { id="cluster_380095"; isCluster="true"; label="Exchange"; 152014 [id="node_152014" labelType="html" label="ShuffledRowRDD [152014] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380094 { id="cluster_380094"; isCluster="true"; label="InMemoryTableScan"; 152015 [id="node_152015" labelType="html" label="MapPartitionsRDD [152015] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 152016 [id="node_152016" labelType="html" label="Exchange hashpartitioning(worklistShardItemId#3571715L, 30), REPARTITION_BY_NUM, [plan_id=1023373]\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=1023369]\n +- HashAggregate(keys=[demandChannel#3571718, shardId#3571714, knownfloatingpointnormalized(transform(kpis#3571720, lambdafunction(knownfloatingpointnormalized(if (isnull(lambda arg#3575998)) null else named_struct(label, lambda arg#3575998.label, dateTime, lambda arg#3575998.dateTime, value, knownfloatingpointnormalized(normalizenanandzero(lambda arg#3575998.value)))), lambda ... [152016] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380165 { id="cluster_380165"; isCluster="true"; label="InMemoryTableScan"; 152026 [id="node_152026" labelType="html" label="MapPartitionsRDD [152026] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 152027 [id="node_152027" labelType="html" label="MapPartitionsRDD [152027] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; 152028 [id="node_152028" labelType="html" label="MapPartitionsRDD [152028] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380164 { id="cluster_380164"; isCluster="true"; label="DeserializeToObject"; 152029 [id="node_152029" labelType="html" label="MapPartitionsRDD [152029] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380166 { id="cluster_380166"; isCluster="true"; label="mapPartitions"; 152031 [id="node_152031" labelType="html" label="MapPartitionsRDD [152031] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380167 { id="cluster_380167"; isCluster="true"; label="union"; 152032 [id="node_152032" labelType="html" label="UnionRDD [152032] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_380168 { id="cluster_380168"; isCluster="true"; label="keyBy"; 152033 [id="node_152033" labelType="html" label="MapPartitionsRDD [152033] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151920->151921; 151921->151922; 152014->152015; 152015->152016; 152016->152026; 152026->152027; 152027->152028; 152028->152029; 152029->152030; 152030->152031; 151922->152032; 152031->152032; 152032->152033; }