digraph G {
subgraph clusterstage_512309 {
label="Stage 512309";
subgraph cluster6293643 {
label="Scan csv ";
3619286 [labelType="html" label="FileScanRDD [3619286]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619287 [labelType="html" label="MapPartitionsRDD [3619287]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293639 {
label="WholeStageCodegen (1)";
3619288 [labelType="html" label="MapPartitionsRDD [3619288]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293638 {
label="InMemoryTableScan";
3619289 [labelType="html" label="MapPartitionsRDD [3619289]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619290 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94240395 = NA) OR (cap#94240395 = null)) THEN null ELSE cast(cap#94240395 as float) END AS cap#94240631, CASE WHEN ((retIC#94240396 = NA) OR (retIC#94240396 = null)) THEN null ELSE cast(retIC#94240396 as float) END AS retIC#94240633, CASE WHEN ((resretIC#94240397 = NA) OR (resretIC#94240397 = null)) THEN null ELSE cast(resretIC#94240397 as float) END AS resretIC#94240635, CASE WHEN ((numcos#94240398 = NA) OR (numcos#94240398 = null)) THEN null ELSE cast(numcos#94240398 as float) END AS numcos#94240637, CASE WHEN ((numdates#94240399 = NA) OR (numdates#94240399 = null)) THEN null ELSE cast(numdates#94240399 as int) END AS numdates#94240639, CASE WHEN ((annual_bmret#94240400 = NA) OR (annual_bmret#94240400 = null)) THEN null ELSE cast(annual_bmret#94240400 as float) END AS annual_bmret#94240641, CASE WHEN ((annual_ret#94240401 = NA) OR (annual_ret#94240401 = null)) THEN null ELSE cast(annual_ret#94240401 as float) END AS annual_ret#94240643, CASE WHEN ((std_ret#94240402 = NA) OR ... [3619290] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293814 {
label="InMemoryTableScan";
3619372 [labelType="html" label="MapPartitionsRDD [3619372]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619373 [labelType="html" label="MapPartitionsRDD [3619373]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619374 [labelType="html" label="MapPartitionsRDD [3619374]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293810 {
label="WholeStageCodegen (1)";
3619375 [labelType="html" label="MapPartitionsRDD [3619375]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293780 {
label="WholeStageCodegen (3)";
3619376 [labelType="html" label="MapPartitionsRDD [3619376]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619286->3619287;
3619287->3619288;
3619288->3619289;
3619289->3619290;
3619290->3619372;
3619372->3619373;
3619373->3619374;
3619374->3619375;
3619375->3619376;
}