digraph G {
subgraph clusterstage_512754 {
label="Stage 512754";
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"];
}
subgraph cluster6299452 {
label="InMemoryTableScan";
3622611 [labelType="html" label="MapPartitionsRDD [3622611]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622612 [labelType="html" label="MapPartitionsRDD [3622612]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622613 [labelType="html" label="MapPartitionsRDD [3622613]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299448 {
label="WholeStageCodegen (1)";
3622614 [labelType="html" label="MapPartitionsRDD [3622614]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299397 {
label="WholeStageCodegen (3)";
3622615 [labelType="html" label="MapPartitionsRDD [3622615]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3622520->3622521;
3622521->3622522;
3622522->3622523;
3622523->3622524;
3622524->3622611;
3622611->3622612;
3622612->3622613;
3622613->3622614;
3622614->3622615;
}