digraph G {
subgraph clusterstage_512679 {
label="Stage 512679";
subgraph cluster6298319 {
label="Scan csv ";
3621977 [labelType="html" label="FileScanRDD [3621977]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621978 [labelType="html" label="MapPartitionsRDD [3621978]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6298315 {
label="WholeStageCodegen (1)";
3621979 [labelType="html" label="MapPartitionsRDD [3621979]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6298314 {
label="InMemoryTableScan";
3621980 [labelType="html" label="MapPartitionsRDD [3621980]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3621981 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94310698 = NA) OR (cap#94310698 = null)) THEN null ELSE cast(cap#94310698 as float) END AS cap#94311010, CASE WHEN ((retIC#94310699 = NA) OR (retIC#94310699 = null)) THEN null ELSE cast(retIC#94310699 as float) END AS retIC#94311011, CASE WHEN ((resretIC#94310700 = NA) OR (resretIC#94310700 = null)) THEN null ELSE cast(resretIC#94310700 as float) END AS resretIC#94311012, CASE WHEN ((numcos#94310701 = NA) OR (numcos#94310701 = null)) THEN null ELSE cast(numcos#94310701 as float) END AS numcos#94311013, CASE WHEN ((numdates#94310702 = NA) OR (numdates#94310702 = null)) THEN null ELSE cast(numdates#94310702 as int) END AS numdates#94311014, CASE WHEN ((annual_bmret#94310703 = NA) OR (annual_bmret#94310703 = null)) THEN null ELSE cast(annual_bmret#94310703 as float) END AS annual_bmret#94311019, CASE WHEN ((annual_ret#94310704 = NA) OR (annual_ret#94310704 = null)) THEN null ELSE cast(annual_ret#94310704 as float) END AS annual_ret#94311020, CASE WHEN ((std_ret#94310705 = NA) OR ... [3621981] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6298489 {
label="InMemoryTableScan";
3622063 [labelType="html" label="MapPartitionsRDD [3622063]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622064 [labelType="html" label="MapPartitionsRDD [3622064]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622065 [labelType="html" label="MapPartitionsRDD [3622065]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6298470 {
label="WholeStageCodegen (1)";
3622069 [labelType="html" label="MapPartitionsRDD [3622069]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6298468 {
label="WholeStageCodegen (3)";
3622070 [labelType="html" label="MapPartitionsRDD [3622070]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3621977->3621978;
3621978->3621979;
3621979->3621980;
3621980->3621981;
3621981->3622063;
3622063->3622064;
3622064->3622065;
3622065->3622069;
3622069->3622070;
}