digraph G {
subgraph clusterstage_513102 {
label="Stage 513102";
subgraph cluster6303802 {
label="Scan csv ";
3625135 [labelType="html" label="FileScanRDD [3625135]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625136 [labelType="html" label="MapPartitionsRDD [3625136]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303799 {
label="WholeStageCodegen (1)";
3625137 [labelType="html" label="MapPartitionsRDD [3625137]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303798 {
label="InMemoryTableScan";
3625138 [labelType="html" label="MapPartitionsRDD [3625138]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625139 [labelType="html" label="*(1) Project [CASE WHEN (group#94392035 = null) THEN null ELSE group#94392035 END AS group#94392140, CASE WHEN ((annual_bmret#94392036 = NA) OR (annual_bmret#94392036 = null)) THEN null ELSE cast(annual_bmret#94392036 as float) END AS annual_bmret#94392142, CASE WHEN ((annual_ret#94392037 = NA) OR (annual_ret#94392037 = null)) THEN null ELSE cast(annual_ret#94392037 as float) END AS annual_ret#94392144, CASE WHEN ((std_ret#94392038 = NA) OR (std_ret#94392038 = null)) THEN null ELSE cast(std_ret#94392038 as float) END AS std_ret#94392146, CASE WHEN ((Sharpe_ret#94392039 = NA) OR (Sharpe_ret#94392039 = null)) THEN null ELSE cast(Sharpe_ret#94392039 as float) END AS Sharpe_ret#94392147, CASE WHEN ((PctPos_ret#94392040 = NA) OR (PctPos_ret#94392040 = null)) THEN null ELSE cast(PctPos_ret#94392040 as float) END AS PctPos_ret#94392148, CASE WHEN ((TR_ret#94392041 = NA) OR (TR_ret#94392041 = null)) THEN null ELSE cast(TR_ret#94392041 as float) END AS TR_ret#94392149, CASE WHEN ((IR_ret#94392042 = NA) OR (IR_ret#9... [3625139] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625140 [labelType="html" label="MapPartitionsRDD [3625140]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625141 [labelType="html" label="MapPartitionsRDD [3625141]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625142 [labelType="html" label="MapPartitionsRDD [3625142]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303781 {
label="WholeStageCodegen (2)";
3625143 [labelType="html" label="MapPartitionsRDD [3625143]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303780 {
label="InMemoryTableScan";
3625144 [labelType="html" label="MapPartitionsRDD [3625144]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625145 [labelType="html" label="*(2) Project [Category#94152530, Label#94152531, annual_ret#94392144, Sharpe_ret#94392147, PctPos_ret#94392148, annual_resret#94392151, Sharpe_resret#94392175, PctPos_resret#94392177, annual_retnet#94392180, Sharpe_retnet#94392182, PctPos_retnet#94392183]\n+- *(2) BroadcastHashJoin [group#94392140], [group#94152529], Inner, BuildRight, false\n :- *(2) Filter isnotnull(group#94392140)\n : +- InMemoryTableScan [group#94392140, annual_ret#94392144, Sharpe_ret#94392147, PctPos_ret#94392148, annual_resret#94392151, Sharpe_resret#94392175, PctPos_resret#94392177, annual_retnet#94392180, Sharpe_retnet#94392182, PctPos_retnet#94392183], [isnotnull(group#94392140)]\n : +- InMemoryRelation [group#94392140, annual_bmret#94392142, annual_ret#94392144, std_ret#94392146, Sharpe_ret#94392147, PctPos_ret#94392148, TR_ret#94392149, IR_ret#94392150, annual_resret#94392151, std_resret#94392152, Sharpe_resret#94392175, PctPos_resret#94392177, TR_resret#94392178, IR_resret#94392179, annual_retnet#94392180, std_retnet... [3625145] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625146 [labelType="html" label="MapPartitionsRDD [3625146]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625147 [labelType="html" label="MapPartitionsRDD [3625147]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625148 [labelType="html" label="MapPartitionsRDD [3625148]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303779 {
label="CollectLimit";
3625149 [labelType="html" label="MapPartitionsRDD [3625149]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303803 {
label="mapPartitionsInternal";
3625150 [labelType="html" label="MapPartitionsRDD [3625150]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303804 {
label="map";
3625151 [labelType="html" label="MapPartitionsRDD [3625151]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625135->3625136;
3625136->3625137;
3625137->3625138;
3625138->3625139;
3625139->3625140;
3625140->3625141;
3625141->3625142;
3625142->3625143;
3625143->3625144;
3625144->3625145;
3625145->3625146;
3625146->3625147;
3625147->3625148;
3625148->3625149;
3625149->3625150;
3625150->3625151;
}
3625139
3625145