digraph G {
subgraph clusterstage_512977 {
label="Stage 512977";
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 cluster6302270 {
label="InMemoryTableScan";
3624246 [labelType="html" label="MapPartitionsRDD [3624246]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624247 [labelType="html" label="MapPartitionsRDD [3624247]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624248 [labelType="html" label="MapPartitionsRDD [3624248]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302260 {
label="WholeStageCodegen (1)";
3624249 [labelType="html" label="MapPartitionsRDD [3624249]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302239 {
label="WholeStageCodegen (2)";
3624250 [labelType="html" label="MapPartitionsRDD [3624250]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624143->3624144;
3624144->3624145;
3624145->3624146;
3624146->3624147;
3624147->3624246;
3624246->3624247;
3624247->3624248;
3624248->3624249;
3624249->3624250;
}