digraph G {
subgraph clusterstage_511634 {
label="Stage 511634";
subgraph cluster6285695 {
label="Scan csv ";
3614747 [labelType="html" label="FileScanRDD [3614747]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614748 [labelType="html" label="MapPartitionsRDD [3614748]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285692 {
label="WholeStageCodegen (1)";
3614749 [labelType="html" label="MapPartitionsRDD [3614749]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285691 {
label="InMemoryTableScan";
3614750 [labelType="html" label="MapPartitionsRDD [3614750]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614751 [labelType="html" label="*(1) Project [CASE WHEN (group#94120694 = null) THEN null ELSE group#94120694 END AS group#94120786, CASE WHEN ((annual_bmret#94120695 = NA) OR (annual_bmret#94120695 = null)) THEN null ELSE cast(annual_bmret#94120695 as float) END AS annual_bmret#94120787, CASE WHEN ((annual_ret#94120696 = NA) OR (annual_ret#94120696 = null)) THEN null ELSE cast(annual_ret#94120696 as float) END AS annual_ret#94120788, CASE WHEN ((std_ret#94120697 = NA) OR (std_ret#94120697 = null)) THEN null ELSE cast(std_ret#94120697 as float) END AS std_ret#94120811, CASE WHEN ((Sharpe_ret#94120698 = NA) OR (Sharpe_ret#94120698 = null)) THEN null ELSE cast(Sharpe_ret#94120698 as float) END AS Sharpe_ret#94120812, CASE WHEN ((PctPos_ret#94120699 = NA) OR (PctPos_ret#94120699 = null)) THEN null ELSE cast(PctPos_ret#94120699 as float) END AS PctPos_ret#94120813, CASE WHEN ((TR_ret#94120700 = NA) OR (TR_ret#94120700 = null)) THEN null ELSE cast(TR_ret#94120700 as float) END AS TR_ret#94120814, CASE WHEN ((IR_ret#94120701 = NA) OR (IR_ret#9... [3614751] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614752 [labelType="html" label="MapPartitionsRDD [3614752]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614753 [labelType="html" label="MapPartitionsRDD [3614753]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614754 [labelType="html" label="MapPartitionsRDD [3614754]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285674 {
label="WholeStageCodegen (2)";
3614755 [labelType="html" label="MapPartitionsRDD [3614755]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285673 {
label="InMemoryTableScan";
3614756 [labelType="html" label="MapPartitionsRDD [3614756]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614757 [labelType="html" label="*(2) Project [Category#93875767, Label#93875768, annual_ret#94120788, Sharpe_ret#94120812, PctPos_ret#94120813, annual_resret#94120816, Sharpe_resret#94120818, PctPos_resret#94120819, annual_retnet#94120823, Sharpe_retnet#94120825, PctPos_retnet#94120826]\n+- *(2) BroadcastHashJoin [group#94120786], [group#93875766], Inner, BuildRight, false\n :- *(2) Filter isnotnull(group#94120786)\n : +- InMemoryTableScan [group#94120786, annual_ret#94120788, Sharpe_ret#94120812, PctPos_ret#94120813, annual_resret#94120816, Sharpe_resret#94120818, PctPos_resret#94120819, annual_retnet#94120823, Sharpe_retnet#94120825, PctPos_retnet#94120826], [isnotnull(group#94120786)]\n : +- InMemoryRelation [group#94120786, annual_bmret#94120787, annual_ret#94120788, std_ret#94120811, Sharpe_ret#94120812, PctPos_ret#94120813, TR_ret#94120814, IR_ret#94120815, annual_resret#94120816, std_resret#94120817, Sharpe_resret#94120818, PctPos_resret#94120819, TR_resret#94120820, IR_resret#94120821, annual_retnet#94120823, std_retnet... [3614757] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614758 [labelType="html" label="MapPartitionsRDD [3614758]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614759 [labelType="html" label="MapPartitionsRDD [3614759]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3614760 [labelType="html" label="MapPartitionsRDD [3614760]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285672 {
label="CollectLimit";
3614761 [labelType="html" label="MapPartitionsRDD [3614761]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285696 {
label="mapPartitionsInternal";
3614762 [labelType="html" label="MapPartitionsRDD [3614762]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6285697 {
label="map";
3614763 [labelType="html" label="MapPartitionsRDD [3614763]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3614747->3614748;
3614748->3614749;
3614749->3614750;
3614750->3614751;
3614751->3614752;
3614752->3614753;
3614753->3614754;
3614754->3614755;
3614755->3614756;
3614756->3614757;
3614757->3614758;
3614758->3614759;
3614759->3614760;
3614760->3614761;
3614761->3614762;
3614762->3614763;
}
3614751
3614757