digraph G {
subgraph clusterstage_513049 {
label="Stage 513049";
subgraph cluster6303011 {
label="Scan csv ";
3624680 [labelType="html" label="FileScanRDD [3624680]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624681 [labelType="html" label="MapPartitionsRDD [3624681]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303008 {
label="WholeStageCodegen (1)";
3624682 [labelType="html" label="MapPartitionsRDD [3624682]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303007 {
label="InMemoryTableScan";
3624683 [labelType="html" label="MapPartitionsRDD [3624683]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624684 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94382327 = NA) OR (cap#94382327 = null)) THEN null ELSE cast(cap#94382327 as float) END AS cap#94382550, CASE WHEN ((retIC#94382328 = NA) OR (retIC#94382328 = null)) THEN null ELSE cast(retIC#94382328 as float) END AS retIC#94382563, CASE WHEN ((resretIC#94382329 = NA) OR (resretIC#94382329 = null)) THEN null ELSE cast(resretIC#94382329 as float) END AS resretIC#94382565, CASE WHEN ((numcos#94382330 = NA) OR (numcos#94382330 = null)) THEN null ELSE cast(numcos#94382330 as float) END AS numcos#94382567, CASE WHEN ((numdates#94382331 = NA) OR (numdates#94382331 = null)) THEN null ELSE cast(numdates#94382331 as int) END AS numdates#94382568, CASE WHEN ((annual_bmret#94382332 = NA) OR (annual_bmret#94382332 = null)) THEN null ELSE cast(annual_bmret#94382332 as float) END AS annual_bmret#94382569, CASE WHEN ((annual_ret#94382333 = NA) OR (annual_ret#94382333 = null)) THEN null ELSE cast(annual_ret#94382333 as float) END AS annual_ret#94382570, CASE WHEN ((std_ret#94382334 = NA) OR ... [3624684] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303171 {
label="InMemoryTableScan";
3624766 [labelType="html" label="MapPartitionsRDD [3624766]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624767 [labelType="html" label="MapPartitionsRDD [3624767]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624768 [labelType="html" label="MapPartitionsRDD [3624768]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303166 {
label="WholeStageCodegen (1)";
3624769 [labelType="html" label="MapPartitionsRDD [3624769]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303159 {
label="WholeStageCodegen (2)";
3624770 [labelType="html" label="MapPartitionsRDD [3624770]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624680->3624681;
3624681->3624682;
3624682->3624683;
3624683->3624684;
3624684->3624766;
3624766->3624767;
3624767->3624768;
3624768->3624769;
3624769->3624770;
}