digraph G {
subgraph clusterstage_512383 {
label="Stage 512383";
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"];
}
subgraph cluster6294742 {
label="InMemoryTableScan";
3619909 [labelType="html" label="MapPartitionsRDD [3619909]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619910 [labelType="html" label="MapPartitionsRDD [3619910]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619911 [labelType="html" label="MapPartitionsRDD [3619911]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294723 {
label="WholeStageCodegen (1)";
3619912 [labelType="html" label="MapPartitionsRDD [3619912]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294721 {
label="WholeStageCodegen (3)";
3619913 [labelType="html" label="MapPartitionsRDD [3619913]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619823->3619824;
3619824->3619825;
3619825->3619826;
3619826->3619827;
3619827->3619909;
3619909->3619910;
3619910->3619911;
3619911->3619912;
3619912->3619913;
}