digraph G {
subgraph clusterstage_512606 {
label="Stage 512606";
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"];
}
subgraph cluster6297568 {
label="InMemoryTableScan";
3621537 [labelType="html" label="MapPartitionsRDD [3621537]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621539 [labelType="html" label="MapPartitionsRDD [3621539]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621541 [labelType="html" label="MapPartitionsRDD [3621541]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297561 {
label="WholeStageCodegen (1)";
3621544 [labelType="html" label="MapPartitionsRDD [3621544]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297531 {
label="WholeStageCodegen (3)";
3621546 [labelType="html" label="MapPartitionsRDD [3621546]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3621440->3621441;
3621441->3621442;
3621442->3621443;
3621443->3621444;
3621444->3621537;
3621537->3621539;
3621539->3621541;
3621541->3621544;
3621544->3621546;
}