digraph G {
subgraph clusterstage_512890 {
label="Stage 512890";
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"];
3623605 [labelType="html" label="MapPartitionsRDD [3623605]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623606 [labelType="html" label="MapPartitionsRDD [3623606]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623607 [labelType="html" label="MapPartitionsRDD [3623607]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301124 {
label="WholeStageCodegen (1)";
3623608 [labelType="html" label="MapPartitionsRDD [3623608]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301122 {
label="WholeStageCodegen (3)";
3623609 [labelType="html" label="MapPartitionsRDD [3623609]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623600->3623601;
3623601->3623602;
3623602->3623603;
3623603->3623604;
3623604->3623605;
3623605->3623606;
3623606->3623607;
3623607->3623608;
3623608->3623609;
}