digraph G {
subgraph clusterstage_512731 {
label="Stage 512731";
subgraph cluster6299102 {
label="Scan csv ";
3622427 [labelType="html" label="FileScanRDD [3622427]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622428 [labelType="html" label="MapPartitionsRDD [3622428]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299099 {
label="WholeStageCodegen (1)";
3622429 [labelType="html" label="MapPartitionsRDD [3622429]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299098 {
label="InMemoryTableScan";
3622430 [labelType="html" label="MapPartitionsRDD [3622430]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622431 [labelType="html" label="*(1) Project [CASE WHEN (group#94320171 = null) THEN null ELSE group#94320171 END AS group#94320430, CASE WHEN ((annual_bmret#94320172 = NA) OR (annual_bmret#94320172 = null)) THEN null ELSE cast(annual_bmret#94320172 as float) END AS annual_bmret#94320432, CASE WHEN ((annual_ret#94320173 = NA) OR (annual_ret#94320173 = null)) THEN null ELSE cast(annual_ret#94320173 as float) END AS annual_ret#94320435, CASE WHEN ((std_ret#94320174 = NA) OR (std_ret#94320174 = null)) THEN null ELSE cast(std_ret#94320174 as float) END AS std_ret#94320438, CASE WHEN ((Sharpe_ret#94320175 = NA) OR (Sharpe_ret#94320175 = null)) THEN null ELSE cast(Sharpe_ret#94320175 as float) END AS Sharpe_ret#94320441, CASE WHEN ((PctPos_ret#94320176 = NA) OR (PctPos_ret#94320176 = null)) THEN null ELSE cast(PctPos_ret#94320176 as float) END AS PctPos_ret#94320443, CASE WHEN ((TR_ret#94320177 = NA) OR (TR_ret#94320177 = null)) THEN null ELSE cast(TR_ret#94320177 as float) END AS TR_ret#94320444, CASE WHEN ((IR_ret#94320178 = NA) OR (IR_ret#9... [3622431] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622432 [labelType="html" label="MapPartitionsRDD [3622432]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622433 [labelType="html" label="MapPartitionsRDD [3622433]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3622434 [labelType="html" label="MapPartitionsRDD [3622434]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299094 {
label="WholeStageCodegen (1)";
3622435 [labelType="html" label="MapPartitionsRDD [3622435]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6299089 {
label="WholeStageCodegen (2)";
3622436 [labelType="html" label="MapPartitionsRDD [3622436]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
}
3622427->3622428;
3622428->3622429;
3622429->3622430;
3622430->3622431;
3622431->3622432;
3622432->3622433;
3622433->3622434;
3622434->3622435;
3622435->3622436;
}