digraph G {
subgraph clusterstage_512243 {
label="Stage 512243";
subgraph cluster6292902 {
label="Scan csv ";
3618880 [labelType="html" label="FileScanRDD [3618880]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618881 [labelType="html" label="MapPartitionsRDD [3618881]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6292899 {
label="WholeStageCodegen (1)";
3618882 [labelType="html" label="MapPartitionsRDD [3618882]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6292898 {
label="InMemoryTableScan";
3618883 [labelType="html" label="MapPartitionsRDD [3618883]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618884 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94230895 = NA) OR (cap#94230895 = null)) THEN null ELSE cast(cap#94230895 as float) END AS cap#94231105, CASE WHEN ((retIC#94230896 = NA) OR (retIC#94230896 = null)) THEN null ELSE cast(retIC#94230896 as float) END AS retIC#94231109, CASE WHEN ((resretIC#94230897 = NA) OR (resretIC#94230897 = null)) THEN null ELSE cast(resretIC#94230897 as float) END AS resretIC#94231113, CASE WHEN ((numcos#94230898 = NA) OR (numcos#94230898 = null)) THEN null ELSE cast(numcos#94230898 as float) END AS numcos#94231117, CASE WHEN ((numdates#94230899 = NA) OR (numdates#94230899 = null)) THEN null ELSE cast(numdates#94230899 as int) END AS numdates#94231121, CASE WHEN ((annual_bmret#94230900 = NA) OR (annual_bmret#94230900 = null)) THEN null ELSE cast(annual_bmret#94230900 as float) END AS annual_bmret#94231124, CASE WHEN ((annual_ret#94230901 = NA) OR (annual_ret#94230901 = null)) THEN null ELSE cast(annual_ret#94230901 as float) END AS annual_ret#94231129, CASE WHEN ((std_ret#94230902 = NA) OR ... [3618884] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618885 [labelType="html" label="MapPartitionsRDD [3618885]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618886 [labelType="html" label="MapPartitionsRDD [3618886]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618887 [labelType="html" label="MapPartitionsRDD [3618887]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6292886 {
label="WholeStageCodegen (1)";
3618888 [labelType="html" label="MapPartitionsRDD [3618888]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6292884 {
label="WholeStageCodegen (3)";
3618889 [labelType="html" label="MapPartitionsRDD [3618889]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3618880->3618881;
3618881->3618882;
3618882->3618883;
3618883->3618884;
3618884->3618885;
3618885->3618886;
3618886->3618887;
3618887->3618888;
3618888->3618889;
}