digraph G {
subgraph clusterstage_512259 {
label="Stage 512259";
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"];
}
subgraph cluster6293120 {
label="InMemoryTableScan";
3618989 [labelType="html" label="MapPartitionsRDD [3618989]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618991 [labelType="html" label="MapPartitionsRDD [3618991]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618992 [labelType="html" label="MapPartitionsRDD [3618992]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293113 {
label="WholeStageCodegen (1)";
3618995 [labelType="html" label="MapPartitionsRDD [3618995]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293099 {
label="WholeStageCodegen (2)";
3618996 [labelType="html" label="MapPartitionsRDD [3618996]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3618880->3618881;
3618881->3618882;
3618882->3618883;
3618883->3618884;
3618884->3618989;
3618989->3618991;
3618991->3618992;
3618992->3618995;
3618995->3618996;
}