digraph G {
subgraph clusterstage_512298 {
label="Stage 512298";
subgraph cluster6293643 {
label="Scan csv ";
3619286 [labelType="html" label="FileScanRDD [3619286]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619287 [labelType="html" label="MapPartitionsRDD [3619287]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293639 {
label="WholeStageCodegen (1)";
3619288 [labelType="html" label="MapPartitionsRDD [3619288]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293638 {
label="InMemoryTableScan";
3619289 [labelType="html" label="MapPartitionsRDD [3619289]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619290 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94240395 = NA) OR (cap#94240395 = null)) THEN null ELSE cast(cap#94240395 as float) END AS cap#94240631, CASE WHEN ((retIC#94240396 = NA) OR (retIC#94240396 = null)) THEN null ELSE cast(retIC#94240396 as float) END AS retIC#94240633, CASE WHEN ((resretIC#94240397 = NA) OR (resretIC#94240397 = null)) THEN null ELSE cast(resretIC#94240397 as float) END AS resretIC#94240635, CASE WHEN ((numcos#94240398 = NA) OR (numcos#94240398 = null)) THEN null ELSE cast(numcos#94240398 as float) END AS numcos#94240637, CASE WHEN ((numdates#94240399 = NA) OR (numdates#94240399 = null)) THEN null ELSE cast(numdates#94240399 as int) END AS numdates#94240639, CASE WHEN ((annual_bmret#94240400 = NA) OR (annual_bmret#94240400 = null)) THEN null ELSE cast(annual_bmret#94240400 as float) END AS annual_bmret#94240641, CASE WHEN ((annual_ret#94240401 = NA) OR (annual_ret#94240401 = null)) THEN null ELSE cast(annual_ret#94240401 as float) END AS annual_ret#94240643, CASE WHEN ((std_ret#94240402 = NA) OR ... [3619290] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619291 [labelType="html" label="MapPartitionsRDD [3619291]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619292 [labelType="html" label="MapPartitionsRDD [3619292]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619293 [labelType="html" label="MapPartitionsRDD [3619293]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293626 {
label="WholeStageCodegen (1)";
3619294 [labelType="html" label="MapPartitionsRDD [3619294]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293625 {
label="WholeStageCodegen (3)";
3619295 [labelType="html" label="MapPartitionsRDD [3619295]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619286->3619287;
3619287->3619288;
3619288->3619289;
3619289->3619290;
3619290->3619291;
3619291->3619292;
3619292->3619293;
3619293->3619294;
3619294->3619295;
}