digraph G {
subgraph clusterstage_512458 {
label="Stage 512458";
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 cluster6295691 {
label="InMemoryTableScan";
3620451 [labelType="html" label="MapPartitionsRDD [3620451]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620452 [labelType="html" label="MapPartitionsRDD [3620452]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620453 [labelType="html" label="MapPartitionsRDD [3620453]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295675 {
label="WholeStageCodegen (1)";
3620454 [labelType="html" label="MapPartitionsRDD [3620454]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295666 {
label="WholeStageCodegen (2)";
3620455 [labelType="html" label="MapPartitionsRDD [3620455]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620360->3620361;
3620361->3620362;
3620362->3620363;
3620363->3620364;
3620364->3620451;
3620451->3620452;
3620452->3620453;
3620453->3620454;
3620454->3620455;
}