digraph G {
subgraph clusterstage_513050 {
label="Stage 513050";
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 cluster6303200 {
label="InMemoryTableScan";
3624771 [labelType="html" label="MapPartitionsRDD [3624771]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624772 [labelType="html" label="MapPartitionsRDD [3624772]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624773 [labelType="html" label="MapPartitionsRDD [3624773]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303189 {
label="WholeStageCodegen (1)";
3624774 [labelType="html" label="MapPartitionsRDD [3624774]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6303185 {
label="WholeStageCodegen (3)";
3624775 [labelType="html" label="MapPartitionsRDD [3624775]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624680->3624681;
3624681->3624682;
3624682->3624683;
3624683->3624684;
3624684->3624771;
3624771->3624772;
3624772->3624773;
3624773->3624774;
3624774->3624775;
}