digraph G {
subgraph clusterstage_513124 {
label="Stage 513124";
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 cluster6304118 {
label="InMemoryTableScan";
3625315 [labelType="html" label="MapPartitionsRDD [3625315]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625316 [labelType="html" label="MapPartitionsRDD [3625316]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3625317 [labelType="html" label="MapPartitionsRDD [3625317]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6304107 {
label="WholeStageCodegen (1)";
3625318 [labelType="html" label="MapPartitionsRDD [3625318]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6304102 {
label="WholeStageCodegen (3)";
3625319 [labelType="html" label="MapPartitionsRDD [3625319]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3625217->3625218;
3625218->3625219;
3625219->3625220;
3625220->3625221;
3625221->3625315;
3625315->3625316;
3625316->3625317;
3625317->3625318;
3625318->3625319;
}