digraph G {
subgraph clusterstage_512311 {
label="Stage 512311";
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 cluster6293835 {
label="InMemoryTableScan";
3619389 [labelType="html" label="MapPartitionsRDD [3619389]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619390 [labelType="html" label="MapPartitionsRDD [3619390]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3619391 [labelType="html" label="MapPartitionsRDD [3619391]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293830 {
label="WholeStageCodegen (1)";
3619392 [labelType="html" label="MapPartitionsRDD [3619392]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6293820 {
label="WholeStageCodegen (2)";
3619393 [labelType="html" label="MapPartitionsRDD [3619393]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3619286->3619287;
3619287->3619288;
3619288->3619289;
3619289->3619290;
3619290->3619389;
3619389->3619390;
3619390->3619391;
3619391->3619392;
3619392->3619393;
}