digraph G {
subgraph clusterstage_512753 {
label="Stage 512753";
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 cluster6299446 {
label="InMemoryTableScan";
3622606 [labelType="html" label="MapPartitionsRDD [3622606]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622607 [labelType="html" label="MapPartitionsRDD [3622607]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622608 [labelType="html" label="MapPartitionsRDD [3622608]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299440 {
label="WholeStageCodegen (1)";
3622609 [labelType="html" label="MapPartitionsRDD [3622609]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299428 {
label="WholeStageCodegen (2)";
3622610 [labelType="html" label="MapPartitionsRDD [3622610]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3622520->3622521;
3622521->3622522;
3622522->3622523;
3622523->3622524;
3622524->3622606;
3622606->3622607;
3622607->3622608;
3622608->3622609;
3622609->3622610;
}