digraph G {
subgraph clusterstage_513125 {
label="Stage 513125";
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"];
}
subgraph cluster6304137 {
label="InMemoryTableScan";
3625320 [labelType="html" label="MapPartitionsRDD [3625320]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625321 [labelType="html" label="MapPartitionsRDD [3625321]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625322 [labelType="html" label="MapPartitionsRDD [3625322]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6304132 {
label="WholeStageCodegen (1)";
3625323 [labelType="html" label="MapPartitionsRDD [3625323]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6304124 {
label="WholeStageCodegen (2)";
3625324 [labelType="html" label="MapPartitionsRDD [3625324]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3625217->3625218;
3625218->3625219;
3625219->3625220;
3625220->3625221;
3625221->3625320;
3625320->3625321;
3625321->3625322;
3625322->3625323;
3625323->3625324;
}