digraph G {
subgraph clusterstage_512920 {
label="Stage 512920";
subgraph cluster6301139 {
label="Scan csv ";
3623600 [labelType="html" label="FileScanRDD [3623600]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623601 [labelType="html" label="MapPartitionsRDD [3623601]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301136 {
label="WholeStageCodegen (1)";
3623602 [labelType="html" label="MapPartitionsRDD [3623602]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301135 {
label="InMemoryTableScan";
3623603 [labelType="html" label="MapPartitionsRDD [3623603]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3623604 [labelType="html" label="*(1) Project [CASE WHEN ((cap#94353974 = NA) OR (cap#94353974 = null)) THEN null ELSE cast(cap#94353974 as float) END AS cap#94354236, CASE WHEN ((retIC#94353975 = NA) OR (retIC#94353975 = null)) THEN null ELSE cast(retIC#94353975 as float) END AS retIC#94354237, CASE WHEN ((resretIC#94353976 = NA) OR (resretIC#94353976 = null)) THEN null ELSE cast(resretIC#94353976 as float) END AS resretIC#94354238, CASE WHEN ((numcos#94353977 = NA) OR (numcos#94353977 = null)) THEN null ELSE cast(numcos#94353977 as float) END AS numcos#94354239, CASE WHEN ((numdates#94353978 = NA) OR (numdates#94353978 = null)) THEN null ELSE cast(numdates#94353978 as int) END AS numdates#94354240, CASE WHEN (annual_bmret#94353979 = null) THEN null ELSE annual_bmret#94353979 END AS annual_bmret#94354241, CASE WHEN ((annual_ret#94353980 = NA) OR (annual_ret#94353980 = null)) THEN null ELSE cast(annual_ret#94353980 as float) END AS annual_ret#94354242, CASE WHEN ((std_ret#94353981 = NA) OR (std_ret#94353981 = null)) THEN null ELSE cast(st... [3623604] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301344 {
label="InMemoryTableScan";
3623719 [labelType="html" label="MapPartitionsRDD [3623719]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623720 [labelType="html" label="MapPartitionsRDD [3623720]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623722 [labelType="html" label="MapPartitionsRDD [3623722]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301314 {
label="WholeStageCodegen (2)";
3623727 [labelType="html" label="MapPartitionsRDD [3623727]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301313 {
label="InMemoryTableScan";
3623729 [labelType="html" label="MapPartitionsRDD [3623729]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623730 [labelType="html" label="*(2) Project [ret_large#94356777, ret_small#94356807, (ret_large#94356777 - ret_small#94356807) AS differential#94356893]\n+- *(2) BroadcastNestedLoopJoin BuildRight, Cross\n :- *(2) Project [annual_ret#94354242 AS ret_large#94356777]\n : +- *(2) Filter (isnotnull(cap#94354236) AND (cap#94354236 = 1.0))\n : +- InMemoryTableScan [annual_ret#94354242, cap#94354236], [isnotnull(cap#94354236), (cap#94354236 = 1.0)]\n : +- InMemoryRelation [cap#94354236, retIC#94354237, resretIC#94354238, numcos#94354239, numdates#94354240, annual_bmret#94354241, annual_ret#94354242, std_ret#94354243, Sharpe_ret#94354244, PctPos_ret#94354262, TR_ret#94354263, IR_ret#94354264, annual_resret#94354276, std_resret#94354277, Sharpe_resret#94354280, PctPos_resret#94354281, TR_resret#94354282, IR_resret#94354283, annual_retnet#94354284, std_retnet#94354285, Sharpe_retnet#94354286, PctPos_retnet#94354287, TR_retnet#94354288, IR_retnet#94354289, ... 2 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3623730] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301485 {
label="InMemoryTableScan";
3623795 [labelType="html" label="MapPartitionsRDD [3623795]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623796 [labelType="html" label="MapPartitionsRDD [3623796]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623797 [labelType="html" label="MapPartitionsRDD [3623797]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301482 {
label="WholeStageCodegen (1)";
3623798 [labelType="html" label="MapPartitionsRDD [3623798]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301481 {
label="CollectLimit";
3623799 [labelType="html" label="MapPartitionsRDD [3623799]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301486 {
label="mapPartitionsInternal";
3623800 [labelType="html" label="MapPartitionsRDD [3623800]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301487 {
label="map";
3623801 [labelType="html" label="MapPartitionsRDD [3623801]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623600->3623601;
3623601->3623602;
3623602->3623603;
3623603->3623604;
3623604->3623719;
3623719->3623720;
3623720->3623722;
3623722->3623727;
3623727->3623729;
3623729->3623730;
3623730->3623795;
3623795->3623796;
3623796->3623797;
3623797->3623798;
3623798->3623799;
3623799->3623800;
3623800->3623801;
}
3623604
3623730