digraph G {
subgraph clusterstage_512828 {
label="Stage 512828";
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 cluster6300394 {
label="InMemoryTableScan";
3623149 [labelType="html" label="MapPartitionsRDD [3623149]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623153 [labelType="html" label="MapPartitionsRDD [3623153]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623155 [labelType="html" label="MapPartitionsRDD [3623155]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300389 {
label="WholeStageCodegen (1)";
3623169 [labelType="html" label="MapPartitionsRDD [3623169]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300381 {
label="WholeStageCodegen (2)";
3623170 [labelType="html" label="MapPartitionsRDD [3623170]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623063->3623064;
3623064->3623065;
3623065->3623066;
3623066->3623067;
3623067->3623149;
3623149->3623153;
3623153->3623155;
3623155->3623169;
3623169->3623170;
}