digraph G {
subgraph clusterstage_512605 {
label="Stage 512605";
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 cluster6297559 {
label="InMemoryTableScan";
3621526 [labelType="html" label="MapPartitionsRDD [3621526]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621527 [labelType="html" label="MapPartitionsRDD [3621527]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621528 [labelType="html" label="MapPartitionsRDD [3621528]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297548 {
label="WholeStageCodegen (1)";
3621529 [labelType="html" label="MapPartitionsRDD [3621529]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6297546 {
label="WholeStageCodegen (2)";
3621530 [labelType="html" label="MapPartitionsRDD [3621530]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3621440->3621441;
3621441->3621442;
3621442->3621443;
3621443->3621444;
3621444->3621526;
3621526->3621527;
3621527->3621528;
3621528->3621529;
3621529->3621530;
}