digraph G {
subgraph clusterstage_512901 {
label="Stage 512901";
subgraph cluster6301139 {
label="Scan csv ";
3623600 [labelType="html" label="FileScanRDD [3623600]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623601 [labelType="html" label="MapPartitionsRDD [3623601]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301136 {
label="WholeStageCodegen (1)";
3623602 [labelType="html" label="MapPartitionsRDD [3623602]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301135 {
label="InMemoryTableScan";
3623603 [labelType="html" label="MapPartitionsRDD [3623603]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623604 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94353974 = NA) OR (cap#94353974 = null)) THEN null ELSE cast(cap#94353974 as float) END AS cap#94354236, CASE WHEN ((retIC#94353975 = NA) OR (retIC#94353975 = null)) THEN null ELSE cast(retIC#94353975 as float) END AS retIC#94354237, CASE WHEN ((resretIC#94353976 = NA) OR (resretIC#94353976 = null)) THEN null ELSE cast(resretIC#94353976 as float) END AS resretIC#94354238, CASE WHEN ((numcos#94353977 = NA) OR (numcos#94353977 = null)) THEN null ELSE cast(numcos#94353977 as float) END AS numcos#94354239, CASE WHEN ((numdates#94353978 = NA) OR (numdates#94353978 = null)) THEN null ELSE cast(numdates#94353978 as int) END AS numdates#94354240, CASE WHEN (annual_bmret#94353979 = null) THEN null ELSE annual_bmret#94353979 END AS annual_bmret#94354241, CASE WHEN ((annual_ret#94353980 = NA) OR (annual_ret#94353980 = null)) THEN null ELSE cast(annual_ret#94353980 as float) END AS annual_ret#94354242, CASE WHEN ((std_ret#94353981 = NA) OR (std_ret#94353981 = null)) THEN null ELSE cast(st... [3623604] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301305 {
label="InMemoryTableScan";
3623686 [labelType="html" label="MapPartitionsRDD [3623686]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623687 [labelType="html" label="MapPartitionsRDD [3623687]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623688 [labelType="html" label="MapPartitionsRDD [3623688]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301281 {
label="WholeStageCodegen (1)";
3623689 [labelType="html" label="MapPartitionsRDD [3623689]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301279 {
label="WholeStageCodegen (3)";
3623690 [labelType="html" label="MapPartitionsRDD [3623690]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623600->3623601;
3623601->3623602;
3623602->3623603;
3623603->3623604;
3623604->3623686;
3623686->3623687;
3623687->3623688;
3623688->3623689;
3623689->3623690;
}