digraph G {
subgraph clusterstage_512976 {
label="Stage 512976";
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"];
}
subgraph cluster6302258 {
label="InMemoryTableScan";
3624241 [labelType="html" label="MapPartitionsRDD [3624241]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624242 [labelType="html" label="MapPartitionsRDD [3624242]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624243 [labelType="html" label="MapPartitionsRDD [3624243]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302240 {
label="WholeStageCodegen (1)";
3624244 [labelType="html" label="MapPartitionsRDD [3624244]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302235 {
label="WholeStageCodegen (3)";
3624245 [labelType="html" label="MapPartitionsRDD [3624245]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624143->3624144;
3624144->3624145;
3624145->3624146;
3624146->3624147;
3624147->3624241;
3624241->3624242;
3624242->3624243;
3624243->3624244;
3624244->3624245;
}