digraph G {
subgraph clusterstage_512742 {
label="Stage 512742";
subgraph cluster6299263 {
label="Scan csv ";
3622520 [labelType="html" label="FileScanRDD [3622520]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622521 [labelType="html" label="MapPartitionsRDD [3622521]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299259 {
label="WholeStageCodegen (1)";
3622522 [labelType="html" label="MapPartitionsRDD [3622522]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299258 {
label="InMemoryTableScan";
3622523 [labelType="html" label="MapPartitionsRDD [3622523]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622524 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94324657 = NA) OR (cap#94324657 = null)) THEN null ELSE cast(cap#94324657 as float) END AS cap#94324901, CASE WHEN ((retIC#94324658 = NA) OR (retIC#94324658 = null)) THEN null ELSE cast(retIC#94324658 as float) END AS retIC#94324914, CASE WHEN ((resretIC#94324659 = NA) OR (resretIC#94324659 = null)) THEN null ELSE cast(resretIC#94324659 as float) END AS resretIC#94324916, CASE WHEN ((numcos#94324660 = NA) OR (numcos#94324660 = null)) THEN null ELSE cast(numcos#94324660 as float) END AS numcos#94324920, CASE WHEN ((numdates#94324661 = NA) OR (numdates#94324661 = null)) THEN null ELSE cast(numdates#94324661 as float) END AS numdates#94324922, CASE WHEN ((annual_bmret#94324662 = NA) OR (annual_bmret#94324662 = null)) THEN null ELSE cast(annual_bmret#94324662 as float) END AS annual_bmret#94324925, CASE WHEN ((annual_ret#94324663 = NA) OR (annual_ret#94324663 = null)) THEN null ELSE cast(annual_ret#94324663 as float) END AS annual_ret#94324984, CASE WHEN ((std_ret#94324664 = NA) O... [3622524] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622525 [labelType="html" label="MapPartitionsRDD [3622525]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622526 [labelType="html" label="MapPartitionsRDD [3622526]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622527 [labelType="html" label="MapPartitionsRDD [3622527]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299247 {
label="WholeStageCodegen (1)";
3622528 [labelType="html" label="MapPartitionsRDD [3622528]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299245 {
label="WholeStageCodegen (3)";
3622529 [labelType="html" label="MapPartitionsRDD [3622529]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3622520->3622521;
3622521->3622522;
3622522->3622523;
3622523->3622524;
3622524->3622525;
3622525->3622526;
3622526->3622527;
3622527->3622528;
3622528->3622529;
}