digraph G {
subgraph clusterstage_511657 {
label="Stage 511657";
subgraph cluster6285848 {
label="Scan csv ";
3614835 [labelType="html" label="FileScanRDD [3614835]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614836 [labelType="html" label="MapPartitionsRDD [3614836]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6285844 {
label="WholeStageCodegen (1)";
3614837 [labelType="html" label="MapPartitionsRDD [3614837]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6285843 {
label="InMemoryTableScan";
3614838 [labelType="html" label="MapPartitionsRDD [3614838]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614839 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94125227 = NA) OR (cap#94125227 = null)) THEN null ELSE cast(cap#94125227 as float) END AS cap#94125439, CASE WHEN ((retIC#94125228 = NA) OR (retIC#94125228 = null)) THEN null ELSE cast(retIC#94125228 as float) END AS retIC#94125440, CASE WHEN ((resretIC#94125229 = NA) OR (resretIC#94125229 = null)) THEN null ELSE cast(resretIC#94125229 as float) END AS resretIC#94125441, CASE WHEN ((numcos#94125230 = NA) OR (numcos#94125230 = null)) THEN null ELSE cast(numcos#94125230 as float) END AS numcos#94125442, CASE WHEN ((numdates#94125231 = NA) OR (numdates#94125231 = null)) THEN null ELSE cast(numdates#94125231 as int) END AS numdates#94125443, CASE WHEN ((annual_bmret#94125232 = NA) OR (annual_bmret#94125232 = null)) THEN null ELSE cast(annual_bmret#94125232 as float) END AS annual_bmret#94125456, CASE WHEN ((annual_ret#94125233 = NA) OR (annual_ret#94125233 = null)) THEN null ELSE cast(annual_ret#94125233 as float) END AS annual_ret#94125545, CASE WHEN ((std_ret#94125234 = NA) OR ... [3614839] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6286038 {
label="InMemoryTableScan";
3614932 [labelType="html" label="MapPartitionsRDD [3614932]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614934 [labelType="html" label="MapPartitionsRDD [3614934]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614936 [labelType="html" label="MapPartitionsRDD [3614936]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6286033 {
label="WholeStageCodegen (1)";
3614938 [labelType="html" label="MapPartitionsRDD [3614938]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6286009 {
label="WholeStageCodegen (2)";
3614939 [labelType="html" label="MapPartitionsRDD [3614939]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3614835->3614836;
3614836->3614837;
3614837->3614838;
3614838->3614839;
3614839->3614932;
3614932->3614934;
3614934->3614936;
3614936->3614938;
3614938->3614939;
}