digraph G {
subgraph clusterstage_513038 {
label="Stage 513038";
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"];
3624685 [labelType="html" label="MapPartitionsRDD [3624685]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624686 [labelType="html" label="MapPartitionsRDD [3624686]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3624687 [labelType="html" label="MapPartitionsRDD [3624687]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302995 {
label="WholeStageCodegen (1)";
3624688 [labelType="html" label="MapPartitionsRDD [3624688]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6302993 {
label="WholeStageCodegen (3)";
3624689 [labelType="html" label="MapPartitionsRDD [3624689]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3624680->3624681;
3624681->3624682;
3624682->3624683;
3624683->3624684;
3624684->3624685;
3624685->3624686;
3624686->3624687;
3624687->3624688;
3624688->3624689;
}