digraph G {
subgraph clusterstage_512531 {
label="Stage 512531";
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 cluster6296605 {
label="InMemoryTableScan";
3620983 [labelType="html" label="MapPartitionsRDD [3620983]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620984 [labelType="html" label="MapPartitionsRDD [3620984]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620985 [labelType="html" label="MapPartitionsRDD [3620985]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296599 {
label="WholeStageCodegen (1)";
3620986 [labelType="html" label="MapPartitionsRDD [3620986]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6296597 {
label="WholeStageCodegen (3)";
3620987 [labelType="html" label="MapPartitionsRDD [3620987]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620897->3620898;
3620898->3620899;
3620899->3620900;
3620900->3620901;
3620901->3620983;
3620983->3620984;
3620984->3620985;
3620985->3620986;
3620986->3620987;
}