digraph G {
subgraph clusterstage_512372 {
label="Stage 512372";
subgraph cluster6294576 {
label="Scan csv ";
3619823 [labelType="html" label="FileScanRDD [3619823]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619824 [labelType="html" label="MapPartitionsRDD [3619824]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294572 {
label="WholeStageCodegen (1)";
3619825 [labelType="html" label="MapPartitionsRDD [3619825]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294571 {
label="InMemoryTableScan";
3619826 [labelType="html" label="MapPartitionsRDD [3619826]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619827 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94254752 = NA) OR (cap#94254752 = null)) THEN null ELSE cast(cap#94254752 as float) END AS cap#94254941, CASE WHEN ((retIC#94254753 = NA) OR (retIC#94254753 = null)) THEN null ELSE cast(retIC#94254753 as float) END AS retIC#94254943, CASE WHEN ((resretIC#94254754 = NA) OR (resretIC#94254754 = null)) THEN null ELSE cast(resretIC#94254754 as float) END AS resretIC#94255036, CASE WHEN ((numcos#94254755 = NA) OR (numcos#94254755 = null)) THEN null ELSE cast(numcos#94254755 as float) END AS numcos#94255037, CASE WHEN ((numdates#94254756 = NA) OR (numdates#94254756 = null)) THEN null ELSE cast(numdates#94254756 as int) END AS numdates#94255038, CASE WHEN ((annual_bmret#94254757 = NA) OR (annual_bmret#94254757 = null)) THEN null ELSE cast(annual_bmret#94254757 as float) END AS annual_bmret#94255039, CASE WHEN ((annual_ret#94254758 = NA) OR (annual_ret#94254758 = null)) THEN null ELSE cast(annual_ret#94254758 as float) END AS annual_ret#94255040, CASE WHEN ((std_ret#94254759 = NA) OR ... [3619827] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619828 [labelType="html" label="MapPartitionsRDD [3619828]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619829 [labelType="html" label="MapPartitionsRDD [3619829]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619830 [labelType="html" label="MapPartitionsRDD [3619830]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294560 {
label="WholeStageCodegen (1)";
3619831 [labelType="html" label="MapPartitionsRDD [3619831]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294558 {
label="WholeStageCodegen (3)";
3619832 [labelType="html" label="MapPartitionsRDD [3619832]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619823->3619824;
3619824->3619825;
3619825->3619826;
3619826->3619827;
3619827->3619828;
3619828->3619829;
3619829->3619830;
3619830->3619831;
3619831->3619832;
}