digraph G {
subgraph clusterstage_512594 {
label="Stage 512594";
subgraph cluster6297386 {
label="Scan csv ";
3621440 [labelType="html" label="FileScanRDD [3621440]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621441 [labelType="html" label="MapPartitionsRDD [3621441]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297382 {
label="WholeStageCodegen (1)";
3621442 [labelType="html" label="MapPartitionsRDD [3621442]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297381 {
label="InMemoryTableScan";
3621443 [labelType="html" label="MapPartitionsRDD [3621443]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621444 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94296341 = NA) OR (cap#94296341 = null)) THEN null ELSE cast(cap#94296341 as float) END AS cap#94296649, CASE WHEN ((retIC#94296342 = NA) OR (retIC#94296342 = null)) THEN null ELSE cast(retIC#94296342 as float) END AS retIC#94296651, CASE WHEN ((resretIC#94296343 = NA) OR (resretIC#94296343 = null)) THEN null ELSE cast(resretIC#94296343 as float) END AS resretIC#94296653, CASE WHEN ((numcos#94296344 = NA) OR (numcos#94296344 = null)) THEN null ELSE cast(numcos#94296344 as float) END AS numcos#94296655, CASE WHEN ((numdates#94296345 = NA) OR (numdates#94296345 = null)) THEN null ELSE cast(numdates#94296345 as int) END AS numdates#94296670, CASE WHEN ((annual_bmret#94296346 = NA) OR (annual_bmret#94296346 = null)) THEN null ELSE cast(annual_bmret#94296346 as float) END AS annual_bmret#94296684, CASE WHEN ((annual_ret#94296347 = NA) OR (annual_ret#94296347 = null)) THEN null ELSE cast(annual_ret#94296347 as float) END AS annual_ret#94296698, CASE WHEN ((std_ret#94296348 = NA) OR ... [3621444] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621445 [labelType="html" label="MapPartitionsRDD [3621445]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621446 [labelType="html" label="MapPartitionsRDD [3621446]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621447 [labelType="html" label="MapPartitionsRDD [3621447]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297370 {
label="WholeStageCodegen (1)";
3621448 [labelType="html" label="MapPartitionsRDD [3621448]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297368 {
label="WholeStageCodegen (3)";
3621449 [labelType="html" label="MapPartitionsRDD [3621449]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3621440->3621441;
3621441->3621442;
3621442->3621443;
3621443->3621444;
3621444->3621445;
3621445->3621446;
3621446->3621447;
3621447->3621448;
3621448->3621449;
}