digraph G {
subgraph clusterstage_512446 {
label="Stage 512446";
subgraph cluster6295509 {
label="Scan csv ";
3620360 [labelType="html" label="FileScanRDD [3620360]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620361 [labelType="html" label="MapPartitionsRDD [3620361]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295505 {
label="WholeStageCodegen (1)";
3620362 [labelType="html" label="MapPartitionsRDD [3620362]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295504 {
label="InMemoryTableScan";
3620363 [labelType="html" label="MapPartitionsRDD [3620363]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620364 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94267827 = NA) OR (cap#94267827 = null)) THEN null ELSE cast(cap#94267827 as float) END AS cap#94268083, CASE WHEN ((retIC#94267828 = NA) OR (retIC#94267828 = null)) THEN null ELSE cast(retIC#94267828 as float) END AS retIC#94268087, CASE WHEN ((resretIC#94267829 = NA) OR (resretIC#94267829 = null)) THEN null ELSE cast(resretIC#94267829 as float) END AS resretIC#94268091, CASE WHEN ((numcos#94267830 = NA) OR (numcos#94267830 = null)) THEN null ELSE cast(numcos#94267830 as float) END AS numcos#94268095, CASE WHEN ((numdates#94267831 = NA) OR (numdates#94267831 = null)) THEN null ELSE cast(numdates#94267831 as int) END AS numdates#94268100, CASE WHEN ((annual_bmret#94267832 = NA) OR (annual_bmret#94267832 = null)) THEN null ELSE cast(annual_bmret#94267832 as float) END AS annual_bmret#94268105, CASE WHEN ((annual_ret#94267833 = NA) OR (annual_ret#94267833 = null)) THEN null ELSE cast(annual_ret#94267833 as float) END AS annual_ret#94268110, CASE WHEN ((std_ret#94267834 = NA) OR ... [3620364] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620365 [labelType="html" label="MapPartitionsRDD [3620365]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620366 [labelType="html" label="MapPartitionsRDD [3620366]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620367 [labelType="html" label="MapPartitionsRDD [3620367]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295493 {
label="WholeStageCodegen (1)";
3620368 [labelType="html" label="MapPartitionsRDD [3620368]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295491 {
label="WholeStageCodegen (3)";
3620369 [labelType="html" label="MapPartitionsRDD [3620369]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620360->3620361;
3620361->3620362;
3620362->3620363;
3620363->3620364;
3620364->3620365;
3620365->3620366;
3620366->3620367;
3620367->3620368;
3620368->3620369;
}