digraph G {
subgraph clusterstage_513112 {
label="Stage 513112";
subgraph cluster6303944 {
label="Scan csv ";
3625217 [labelType="html" label="FileScanRDD [3625217]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625218 [labelType="html" label="MapPartitionsRDD [3625218]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303940 {
label="WholeStageCodegen (1)";
3625219 [labelType="html" label="MapPartitionsRDD [3625219]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303939 {
label="InMemoryTableScan";
3625220 [labelType="html" label="MapPartitionsRDD [3625220]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625221 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94396248 = NA) OR (cap#94396248 = null)) THEN null ELSE cast(cap#94396248 as float) END AS cap#94396456, CASE WHEN ((retIC#94396249 = NA) OR (retIC#94396249 = null)) THEN null ELSE cast(retIC#94396249 as float) END AS retIC#94396457, CASE WHEN ((resretIC#94396250 = NA) OR (resretIC#94396250 = null)) THEN null ELSE cast(resretIC#94396250 as float) END AS resretIC#94396470, CASE WHEN ((numcos#94396251 = NA) OR (numcos#94396251 = null)) THEN null ELSE cast(numcos#94396251 as float) END AS numcos#94396483, CASE WHEN ((numdates#94396252 = NA) OR (numdates#94396252 = null)) THEN null ELSE cast(numdates#94396252 as int) END AS numdates#94396484, CASE WHEN ((annual_bmret#94396253 = NA) OR (annual_bmret#94396253 = null)) THEN null ELSE cast(annual_bmret#94396253 as float) END AS annual_bmret#94396485, CASE WHEN ((annual_ret#94396254 = NA) OR (annual_ret#94396254 = null)) THEN null ELSE cast(annual_ret#94396254 as float) END AS annual_ret#94396486, CASE WHEN ((std_ret#94396255 = NA) OR ... [3625221] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625222 [labelType="html" label="MapPartitionsRDD [3625222]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625223 [labelType="html" label="MapPartitionsRDD [3625223]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625224 [labelType="html" label="MapPartitionsRDD [3625224]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303927 {
label="WholeStageCodegen (1)";
3625225 [labelType="html" label="MapPartitionsRDD [3625225]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303926 {
label="WholeStageCodegen (3)";
3625226 [labelType="html" label="MapPartitionsRDD [3625226]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3625217->3625218;
3625218->3625219;
3625219->3625220;
3625220->3625221;
3625221->3625222;
3625222->3625223;
3625223->3625224;
3625224->3625225;
3625225->3625226;
}