digraph G {
subgraph clusterstage_512258 {
label="Stage 512258";
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 cluster6293114 {
label="InMemoryTableScan";
3618987 [labelType="html" label="MapPartitionsRDD [3618987]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618988 [labelType="html" label="MapPartitionsRDD [3618988]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3618990 [labelType="html" label="MapPartitionsRDD [3618990]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293102 {
label="WholeStageCodegen (1)";
3618993 [labelType="html" label="MapPartitionsRDD [3618993]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293077 {
label="WholeStageCodegen (3)";
3618994 [labelType="html" label="MapPartitionsRDD [3618994]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3618880->3618881;
3618881->3618882;
3618882->3618883;
3618883->3618884;
3618884->3618987;
3618987->3618988;
3618988->3618990;
3618990->3618993;
3618993->3618994;
}