digraph G {
subgraph clusterstage_512457 {
label="Stage 512457";
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"];
}
subgraph cluster6295652 {
label="InMemoryTableScan";
3620446 [labelType="html" label="MapPartitionsRDD [3620446]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620447 [labelType="html" label="MapPartitionsRDD [3620447]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620448 [labelType="html" label="MapPartitionsRDD [3620448]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295647 {
label="WholeStageCodegen (1)";
3620449 [labelType="html" label="MapPartitionsRDD [3620449]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295636 {
label="WholeStageCodegen (3)";
3620450 [labelType="html" label="MapPartitionsRDD [3620450]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620360->3620361;
3620361->3620362;
3620362->3620363;
3620363->3620364;
3620364->3620446;
3620446->3620447;
3620447->3620448;
3620448->3620449;
3620449->3620450;
}