digraph G {
subgraph clusterstage_512829 {
label="Stage 512829";
subgraph cluster6300207 {
label="Scan csv ";
3623063 [labelType="html" label="FileScanRDD [3623063]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623064 [labelType="html" label="MapPartitionsRDD [3623064]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300204 {
label="WholeStageCodegen (1)";
3623065 [labelType="html" label="MapPartitionsRDD [3623065]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300203 {
label="InMemoryTableScan";
3623066 [labelType="html" label="MapPartitionsRDD [3623066]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623067 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94338977 = NA) OR (cap#94338977 = null)) THEN null ELSE cast(cap#94338977 as float) END AS cap#94339344, CASE WHEN ((retIC#94338978 = NA) OR (retIC#94338978 = null)) THEN null ELSE cast(retIC#94338978 as float) END AS retIC#94339345, CASE WHEN ((resretIC#94338979 = NA) OR (resretIC#94338979 = null)) THEN null ELSE cast(resretIC#94338979 as float) END AS resretIC#94339346, CASE WHEN ((numcos#94338980 = NA) OR (numcos#94338980 = null)) THEN null ELSE cast(numcos#94338980 as float) END AS numcos#94339347, CASE WHEN ((numdates#94338981 = NA) OR (numdates#94338981 = null)) THEN null ELSE cast(numdates#94338981 as int) END AS numdates#94339348, CASE WHEN ((annual_bmret#94338982 = NA) OR (annual_bmret#94338982 = null)) THEN null ELSE cast(annual_bmret#94338982 as float) END AS annual_bmret#94339349, CASE WHEN ((annual_ret#94338983 = NA) OR (annual_ret#94338983 = null)) THEN null ELSE cast(annual_ret#94338983 as float) END AS annual_ret#94339350, CASE WHEN ((std_ret#94338984 = NA) OR ... [3623067] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300396 {
label="InMemoryTableScan";
3623150 [labelType="html" label="MapPartitionsRDD [3623150]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623159 [labelType="html" label="MapPartitionsRDD [3623159]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623161 [labelType="html" label="MapPartitionsRDD [3623161]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300365 {
label="WholeStageCodegen (1)";
3623163 [labelType="html" label="MapPartitionsRDD [3623163]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300362 {
label="WholeStageCodegen (3)";
3623165 [labelType="html" label="MapPartitionsRDD [3623165]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623063->3623064;
3623064->3623065;
3623065->3623066;
3623066->3623067;
3623067->3623150;
3623150->3623159;
3623159->3623161;
3623161->3623163;
3623163->3623165;
}