digraph G {
subgraph clusterstage_511705 {
label="Stage 511705";
subgraph cluster6278334 {
label="Scan csv ";
3610509 [labelType="html" label="FileScanRDD [3610509]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3610510 [labelType="html" label="MapPartitionsRDD [3610510]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6278331 {
label="WholeStageCodegen (1)";
3610511 [labelType="html" label="MapPartitionsRDD [3610511]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6278330 {
label="InMemoryTableScan";
3610512 [labelType="html" label="MapPartitionsRDD [3610512]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3610513 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94010439 = NA) OR (cap#94010439 = null)) THEN null ELSE cast(cap#94010439 as float) END AS cap#94010644, CASE WHEN ((retIC#94010440 = NA) OR (retIC#94010440 = null)) THEN null ELSE cast(retIC#94010440 as float) END AS retIC#94010648, CASE WHEN ((resretIC#94010441 = NA) OR (resretIC#94010441 = null)) THEN null ELSE cast(resretIC#94010441 as float) END AS resretIC#94010653, CASE WHEN ((numcos#94010442 = NA) OR (numcos#94010442 = null)) THEN null ELSE cast(numcos#94010442 as float) END AS numcos#94010657, CASE WHEN ((numdates#94010443 = NA) OR (numdates#94010443 = null)) THEN null ELSE cast(numdates#94010443 as int) END AS numdates#94010661, CASE WHEN (annual_bmret#94010444 = null) THEN null ELSE annual_bmret#94010444 END AS annual_bmret#94010666, CASE WHEN ((annual_ret#94010445 = NA) OR (annual_ret#94010445 = null)) THEN null ELSE cast(annual_ret#94010445 as float) END AS annual_ret#94010671, CASE WHEN ((std_ret#94010446 = NA) OR (std_ret#94010446 = null)) THEN null ELSE cast(st... [3610513] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6278549 {
label="InMemoryTableScan";
3610629 [labelType="html" label="MapPartitionsRDD [3610629]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610630 [labelType="html" label="MapPartitionsRDD [3610630]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610631 [labelType="html" label="MapPartitionsRDD [3610631]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278508 {
label="WholeStageCodegen (2)";
3610632 [labelType="html" label="MapPartitionsRDD [3610632]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278507 {
label="InMemoryTableScan";
3610633 [labelType="html" label="MapPartitionsRDD [3610633]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610634 [labelType="html" label="*(2) Project [ret_large#94013861, ret_small#94013891, (ret_large#94013861 - ret_small#94013891) AS differential#94013977]\n+- *(2) BroadcastNestedLoopJoin BuildRight, Cross\n :- *(2) Project [annual_ret#94010671 AS ret_large#94013861]\n : +- *(2) Filter (isnotnull(cap#94010644) AND (cap#94010644 = 1.0))\n : +- InMemoryTableScan [annual_ret#94010671, cap#94010644], [isnotnull(cap#94010644), (cap#94010644 = 1.0)]\n : +- InMemoryRelation [cap#94010644, retIC#94010648, resretIC#94010653, numcos#94010657, numdates#94010661, annual_bmret#94010666, annual_ret#94010671, std_ret#94010676, Sharpe_ret#94010680, PctPos_ret#94010684, TR_ret#94010696, IR_ret#94010697, annual_resret#94010699, std_resret#94010700, Sharpe_resret#94010701, PctPos_resret#94010702, TR_resret#94010703, IR_resret#94010704, annual_retnet#94010705, std_retnet#94010706, Sharpe_retnet#94010707, PctPos_retnet#94010720, TR_retnet#94010722, IR_retnet#94010723, ... 2 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3610634] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286469 {
label="InMemoryTableScan";
3615174 [labelType="html" label="MapPartitionsRDD [3615174]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615175 [labelType="html" label="MapPartitionsRDD [3615175]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615176 [labelType="html" label="MapPartitionsRDD [3615176]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286466 {
label="WholeStageCodegen (1)";
3615177 [labelType="html" label="MapPartitionsRDD [3615177]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286465 {
label="CollectLimit";
3615178 [labelType="html" label="MapPartitionsRDD [3615178]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286470 {
label="mapPartitionsInternal";
3615179 [labelType="html" label="MapPartitionsRDD [3615179]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286471 {
label="map";
3615180 [labelType="html" label="MapPartitionsRDD [3615180]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610509->3610510;
3610510->3610511;
3610511->3610512;
3610512->3610513;
3610513->3610629;
3610629->3610630;
3610630->3610631;
3610631->3610632;
3610632->3610633;
3610633->3610634;
3610634->3615174;
3615174->3615175;
3615175->3615176;
3615176->3615177;
3615177->3615178;
3615178->3615179;
3615179->3615180;
}
3610513
3610634