digraph G {
subgraph clusterstage_511655 {
label="Stage 511655";
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 cluster6286025 {
label="InMemoryTableScan";
3614921 [labelType="html" label="MapPartitionsRDD [3614921]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614922 [labelType="html" label="MapPartitionsRDD [3614922]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3614923 [labelType="html" label="MapPartitionsRDD [3614923]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6286021 {
label="WholeStageCodegen (1)";
3614924 [labelType="html" label="MapPartitionsRDD [3614924]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6286006 {
label="WholeStageCodegen (3)";
3614925 [labelType="html" label="MapPartitionsRDD [3614925]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3614835->3614836;
3614836->3614837;
3614837->3614838;
3614838->3614839;
3614839->3614921;
3614921->3614922;
3614922->3614923;
3614923->3614924;
3614924->3614925;
}