digraph G {
subgraph clusterstage_512902 {
label="Stage 512902";
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 cluster6301325 {
label="InMemoryTableScan";
3623701 [labelType="html" label="MapPartitionsRDD [3623701]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623703 [labelType="html" label="MapPartitionsRDD [3623703]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623704 [labelType="html" label="MapPartitionsRDD [3623704]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301317 {
label="WholeStageCodegen (1)";
3623705 [labelType="html" label="MapPartitionsRDD [3623705]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301314 {
label="WholeStageCodegen (2)";
3623706 [labelType="html" label="MapPartitionsRDD [3623706]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623600->3623601;
3623601->3623602;
3623602->3623603;
3623603->3623604;
3623604->3623701;
3623701->3623703;
3623703->3623704;
3623704->3623705;
3623705->3623706;
}