digraph G {
subgraph clusterstage_512879 {
label="Stage 512879";
subgraph cluster6300990 {
label="Scan csv ";
3623513 [labelType="html" label="FileScanRDD [3623513]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623514 [labelType="html" label="MapPartitionsRDD [3623514]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300987 {
label="WholeStageCodegen (1)";
3623515 [labelType="html" label="MapPartitionsRDD [3623515]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300986 {
label="InMemoryTableScan";
3623516 [labelType="html" label="MapPartitionsRDD [3623516]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623517 [labelType="html" label="*(1) Project [CASE WHEN (group#94348826 = null) THEN null ELSE group#94348826 END AS group#94348918, CASE WHEN (annual_bmret#94348827 = null) THEN null ELSE annual_bmret#94348827 END AS annual_bmret#94348919, CASE WHEN ((annual_ret#94348828 = NA) OR (annual_ret#94348828 = null)) THEN null ELSE cast(annual_ret#94348828 as float) END AS annual_ret#94348920, CASE WHEN ((std_ret#94348829 = NA) OR (std_ret#94348829 = null)) THEN null ELSE cast(std_ret#94348829 as float) END AS std_ret#94348922, CASE WHEN ((Sharpe_ret#94348830 = NA) OR (Sharpe_ret#94348830 = null)) THEN null ELSE cast(Sharpe_ret#94348830 as float) END AS Sharpe_ret#94348923, CASE WHEN ((PctPos_ret#94348831 = NA) OR (PctPos_ret#94348831 = null)) THEN null ELSE cast(PctPos_ret#94348831 as float) END AS PctPos_ret#94348924, CASE WHEN (TR_ret#94348832 = null) THEN null ELSE TR_ret#94348832 END AS TR_ret#94348925, CASE WHEN (IR_ret#94348833 = null) THEN null ELSE IR_ret#94348833 END AS IR_ret#94348926, CASE WHEN ((annual_resret#94348834 = NA) OR (ann... [3623517] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623518 [labelType="html" label="MapPartitionsRDD [3623518]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623519 [labelType="html" label="MapPartitionsRDD [3623519]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623520 [labelType="html" label="MapPartitionsRDD [3623520]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300982 {
label="WholeStageCodegen (1)";
3623521 [labelType="html" label="MapPartitionsRDD [3623521]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6300977 {
label="WholeStageCodegen (2)";
3623522 [labelType="html" label="MapPartitionsRDD [3623522]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3623513->3623514;
3623514->3623515;
3623515->3623516;
3623516->3623517;
3623517->3623518;
3623518->3623519;
3623519->3623520;
3623520->3623521;
3623521->3623522;
}