digraph G {
subgraph clusterstage_512532 {
label="Stage 512532";
subgraph cluster6296442 {
label="Scan csv ";
3620897 [labelType="html" label="FileScanRDD [3620897]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620898 [labelType="html" label="MapPartitionsRDD [3620898]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296438 {
label="WholeStageCodegen (1)";
3620899 [labelType="html" label="MapPartitionsRDD [3620899]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296437 {
label="InMemoryTableScan";
3620900 [labelType="html" label="MapPartitionsRDD [3620900]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620901 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94282446 = NA) OR (cap#94282446 = null)) THEN null ELSE cast(cap#94282446 as float) END AS cap#94282654, CASE WHEN ((retIC#94282447 = NA) OR (retIC#94282447 = null)) THEN null ELSE cast(retIC#94282447 as float) END AS retIC#94282658, CASE WHEN ((resretIC#94282448 = NA) OR (resretIC#94282448 = null)) THEN null ELSE cast(resretIC#94282448 as float) END AS resretIC#94282659, CASE WHEN ((numcos#94282449 = NA) OR (numcos#94282449 = null)) THEN null ELSE cast(numcos#94282449 as float) END AS numcos#94282663, CASE WHEN ((numdates#94282450 = NA) OR (numdates#94282450 = null)) THEN null ELSE cast(numdates#94282450 as int) END AS numdates#94282669, CASE WHEN ((annual_bmret#94282451 = NA) OR (annual_bmret#94282451 = null)) THEN null ELSE cast(annual_bmret#94282451 as float) END AS annual_bmret#94282673, CASE WHEN ((annual_ret#94282452 = NA) OR (annual_ret#94282452 = null)) THEN null ELSE cast(annual_ret#94282452 as float) END AS annual_ret#94282676, CASE WHEN ((std_ret#94282453 = NA) OR ... [3620901] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296624 {
label="InMemoryTableScan";
3620988 [labelType="html" label="MapPartitionsRDD [3620988]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620989 [labelType="html" label="MapPartitionsRDD [3620989]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620990 [labelType="html" label="MapPartitionsRDD [3620990]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296619 {
label="WholeStageCodegen (1)";
3620993 [labelType="html" label="MapPartitionsRDD [3620993]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296612 {
label="WholeStageCodegen (2)";
3620994 [labelType="html" label="MapPartitionsRDD [3620994]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620897->3620898;
3620898->3620899;
3620899->3620900;
3620900->3620901;
3620901->3620988;
3620988->3620989;
3620989->3620990;
3620990->3620993;
3620993->3620994;
}