digraph G {
subgraph clusterstage_511644 {
label="Stage 511644";
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"];
3614840 [labelType="html" label="MapPartitionsRDD [3614840]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614841 [labelType="html" label="MapPartitionsRDD [3614841]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614842 [labelType="html" label="MapPartitionsRDD [3614842]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6285832 {
label="WholeStageCodegen (1)";
3614843 [labelType="html" label="MapPartitionsRDD [3614843]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6285830 {
label="WholeStageCodegen (3)";
3614844 [labelType="html" label="MapPartitionsRDD [3614844]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3614835->3614836;
3614836->3614837;
3614837->3614838;
3614838->3614839;
3614839->3614840;
3614840->3614841;
3614841->3614842;
3614842->3614843;
3614843->3614844;
}