digraph G {
subgraph clusterstage_512441 {
label="Stage 512441";
subgraph cluster6295450 {
label="Scan csv ";
3620329 [labelType="html" label="FileScanRDD [3620329]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620330 [labelType="html" label="MapPartitionsRDD [3620330]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295447 {
label="WholeStageCodegen (1)";
3620331 [labelType="html" label="MapPartitionsRDD [3620331]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295446 {
label="InMemoryTableScan";
3620332 [labelType="html" label="MapPartitionsRDD [3620332]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620333 [labelType="html" label="*(1) Project [CASE WHEN ((sector_id#94267879 = NA) OR (sector_id#94267879 = null)) THEN null ELSE cast(sector_id#94267879 as int) END AS sector_id#94268085, CASE WHEN ((retIC#94267880 = NA) OR (retIC#94267880 = null)) THEN null ELSE cast(retIC#94267880 as float) END AS retIC#94268090, CASE WHEN ((resretIC#94267881 = NA) OR (resretIC#94267881 = null)) THEN null ELSE cast(resretIC#94267881 as float) END AS resretIC#94268094, CASE WHEN ((numcos#94267882 = NA) OR (numcos#94267882 = null)) THEN null ELSE cast(numcos#94267882 as float) END AS numcos#94268096, CASE WHEN ((numdates#94267883 = NA) OR (numdates#94267883 = null)) THEN null ELSE cast(numdates#94267883 as float) END AS numdates#94268099, CASE WHEN ((annual_bmret#94267884 = NA) OR (annual_bmret#94267884 = null)) THEN null ELSE cast(annual_bmret#94267884 as float) END AS annual_bmret#94268103, CASE WHEN ((annual_ret#94267885 = NA) OR (annual_ret#94267885 = null)) THEN null ELSE cast(annual_ret#94267885 as float) END AS annual_ret#94268107, CASE WHEN ((st... [3620333] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620334 [labelType="html" label="MapPartitionsRDD [3620334]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620335 [labelType="html" label="MapPartitionsRDD [3620335]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3620336 [labelType="html" label="MapPartitionsRDD [3620336]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295434 {
label="WholeStageCodegen (1)";
3620337 [labelType="html" label="MapPartitionsRDD [3620337]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6295431 {
label="WholeStageCodegen (3)";
3620338 [labelType="html" label="MapPartitionsRDD [3620338]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3620329->3620330;
3620330->3620331;
3620331->3620332;
3620332->3620333;
3620333->3620334;
3620334->3620335;
3620335->3620336;
3620336->3620337;
3620337->3620338;
}