digraph G {
subgraph clusterstage_512811 {
label="Stage 512811";
subgraph cluster6300148 {
label="Scan csv ";
3623032 [labelType="html" label="FileScanRDD [3623032]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623033 [labelType="html" label="MapPartitionsRDD [3623033]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300145 {
label="WholeStageCodegen (1)";
3623034 [labelType="html" label="MapPartitionsRDD [3623034]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300144 {
label="InMemoryTableScan";
3623035 [labelType="html" label="MapPartitionsRDD [3623035]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623036 [labelType="html" label="*(1) Project [CASE WHEN ((sector_id#94339030 = NA) OR (sector_id#94339030 = null)) THEN null ELSE cast(sector_id#94339030 as int) END AS sector_id#94339267, CASE WHEN ((retIC#94339031 = NA) OR (retIC#94339031 = null)) THEN null ELSE cast(retIC#94339031 as float) END AS retIC#94339268, CASE WHEN ((resretIC#94339032 = NA) OR (resretIC#94339032 = null)) THEN null ELSE cast(resretIC#94339032 as float) END AS resretIC#94339269, CASE WHEN ((numcos#94339033 = NA) OR (numcos#94339033 = null)) THEN null ELSE cast(numcos#94339033 as float) END AS numcos#94339270, CASE WHEN ((numdates#94339034 = NA) OR (numdates#94339034 = null)) THEN null ELSE cast(numdates#94339034 as float) END AS numdates#94339271, CASE WHEN ((annual_bmret#94339035 = NA) OR (annual_bmret#94339035 = null)) THEN null ELSE cast(annual_bmret#94339035 as float) END AS annual_bmret#94339272, CASE WHEN ((annual_ret#94339036 = NA) OR (annual_ret#94339036 = null)) THEN null ELSE cast(annual_ret#94339036 as float) END AS annual_ret#94339444, CASE WHEN ((st... [3623036] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623037 [labelType="html" label="MapPartitionsRDD [3623037]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623038 [labelType="html" label="MapPartitionsRDD [3623038]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623039 [labelType="html" label="MapPartitionsRDD [3623039]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300131 {
label="WholeStageCodegen (1)";
3623040 [labelType="html" label="MapPartitionsRDD [3623040]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300129 {
label="WholeStageCodegen (3)";
3623041 [labelType="html" label="MapPartitionsRDD [3623041]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623032->3623033;
3623033->3623034;
3623034->3623035;
3623035->3623036;
3623036->3623037;
3623037->3623038;
3623038->3623039;
3623039->3623040;
3623040->3623041;
}