digraph G {
subgraph clusterstage_512384 {
label="Stage 512384";
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 cluster6294761 {
label="InMemoryTableScan";
3619916 [labelType="html" label="MapPartitionsRDD [3619916]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619918 [labelType="html" label="MapPartitionsRDD [3619918]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619920 [labelType="html" label="MapPartitionsRDD [3619920]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294756 {
label="WholeStageCodegen (1)";
3619923 [labelType="html" label="MapPartitionsRDD [3619923]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6294748 {
label="WholeStageCodegen (2)";
3619924 [labelType="html" label="MapPartitionsRDD [3619924]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619823->3619824;
3619824->3619825;
3619825->3619826;
3619826->3619827;
3619827->3619916;
3619916->3619918;
3619918->3619920;
3619920->3619923;
3619923->3619924;
}