digraph G {
subgraph clusterstage_512964 {
label="Stage 512964";
subgraph cluster6302078 {
label="Scan csv ";
3624143 [labelType="html" label="FileScanRDD [3624143]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624144 [labelType="html" label="MapPartitionsRDD [3624144]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302075 {
label="WholeStageCodegen (1)";
3624145 [labelType="html" label="MapPartitionsRDD [3624145]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302074 {
label="InMemoryTableScan";
3624146 [labelType="html" label="MapPartitionsRDD [3624146]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624147 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94367812 = NA) OR (cap#94367812 = null)) THEN null ELSE cast(cap#94367812 as float) END AS cap#94368001, CASE WHEN ((retIC#94367813 = NA) OR (retIC#94367813 = null)) THEN null ELSE cast(retIC#94367813 as float) END AS retIC#94368014, CASE WHEN ((resretIC#94367814 = NA) OR (resretIC#94367814 = null)) THEN null ELSE cast(resretIC#94367814 as float) END AS resretIC#94368016, CASE WHEN ((numcos#94367815 = NA) OR (numcos#94367815 = null)) THEN null ELSE cast(numcos#94367815 as float) END AS numcos#94368018, CASE WHEN ((numdates#94367816 = NA) OR (numdates#94367816 = null)) THEN null ELSE cast(numdates#94367816 as int) END AS numdates#94368020, CASE WHEN ((annual_bmret#94367817 = NA) OR (annual_bmret#94367817 = null)) THEN null ELSE cast(annual_bmret#94367817 as float) END AS annual_bmret#94368021, CASE WHEN ((annual_ret#94367818 = NA) OR (annual_ret#94367818 = null)) THEN null ELSE cast(annual_ret#94367818 as float) END AS annual_ret#94368105, CASE WHEN ((std_ret#94367819 = NA) OR ... [3624147] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624148 [labelType="html" label="MapPartitionsRDD [3624148]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624149 [labelType="html" label="MapPartitionsRDD [3624149]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624150 [labelType="html" label="MapPartitionsRDD [3624150]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302061 {
label="WholeStageCodegen (1)";
3624151 [labelType="html" label="MapPartitionsRDD [3624151]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302060 {
label="WholeStageCodegen (3)";
3624152 [labelType="html" label="MapPartitionsRDD [3624152]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624143->3624144;
3624144->3624145;
3624145->3624146;
3624146->3624147;
3624147->3624148;
3624148->3624149;
3624149->3624150;
3624150->3624151;
3624151->3624152;
}