digraph G {
subgraph clusterstage_512954 {
label="Stage 512954";
subgraph cluster6301925 {
label="Scan csv ";
3624055 [labelType="html" label="FileScanRDD [3624055]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624056 [labelType="html" label="MapPartitionsRDD [3624056]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301922 {
label="WholeStageCodegen (1)";
3624057 [labelType="html" label="MapPartitionsRDD [3624057]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301921 {
label="InMemoryTableScan";
3624058 [labelType="html" label="MapPartitionsRDD [3624058]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624059 [labelType="html" label="*(1) Project [CASE WHEN (group#94363595 = null) THEN null ELSE group#94363595 END AS group#94363717, CASE WHEN ((annual_bmret#94363596 = NA) OR (annual_bmret#94363596 = null)) THEN null ELSE cast(annual_bmret#94363596 as float) END AS annual_bmret#94363719, CASE WHEN ((annual_ret#94363597 = NA) OR (annual_ret#94363597 = null)) THEN null ELSE cast(annual_ret#94363597 as float) END AS annual_ret#94363721, CASE WHEN ((std_ret#94363598 = NA) OR (std_ret#94363598 = null)) THEN null ELSE cast(std_ret#94363598 as float) END AS std_ret#94363723, CASE WHEN ((Sharpe_ret#94363599 = NA) OR (Sharpe_ret#94363599 = null)) THEN null ELSE cast(Sharpe_ret#94363599 as float) END AS Sharpe_ret#94363725, CASE WHEN ((PctPos_ret#94363600 = NA) OR (PctPos_ret#94363600 = null)) THEN null ELSE cast(PctPos_ret#94363600 as float) END AS PctPos_ret#94363727, CASE WHEN ((TR_ret#94363601 = NA) OR (TR_ret#94363601 = null)) THEN null ELSE cast(TR_ret#94363601 as float) END AS TR_ret#94363729, CASE WHEN ((IR_ret#94363602 = NA) OR (IR_ret#9... [3624059] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624060 [labelType="html" label="MapPartitionsRDD [3624060]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624061 [labelType="html" label="MapPartitionsRDD [3624061]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624062 [labelType="html" label="MapPartitionsRDD [3624062]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301904 {
label="WholeStageCodegen (2)";
3624063 [labelType="html" label="MapPartitionsRDD [3624063]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301903 {
label="InMemoryTableScan";
3624064 [labelType="html" label="MapPartitionsRDD [3624064]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624065 [labelType="html" label="*(2) Project [Category#94152530, Label#94152531, annual_ret#94363721, Sharpe_ret#94363725, PctPos_ret#94363727, annual_resret#94363733, Sharpe_resret#94363737, PctPos_resret#94363739, annual_retnet#94363745, Sharpe_retnet#94363747, PctPos_retnet#94363748]\n+- *(2) BroadcastHashJoin [group#94363717], [group#94152529], Inner, BuildRight, false\n :- *(2) Filter isnotnull(group#94363717)\n : +- InMemoryTableScan [group#94363717, annual_ret#94363721, Sharpe_ret#94363725, PctPos_ret#94363727, annual_resret#94363733, Sharpe_resret#94363737, PctPos_resret#94363739, annual_retnet#94363745, Sharpe_retnet#94363747, PctPos_retnet#94363748], [isnotnull(group#94363717)]\n : +- InMemoryRelation [group#94363717, annual_bmret#94363719, annual_ret#94363721, std_ret#94363723, Sharpe_ret#94363725, PctPos_ret#94363727, TR_ret#94363729, IR_ret#94363731, annual_resret#94363733, std_resret#94363735, Sharpe_resret#94363737, PctPos_resret#94363739, TR_resret#94363741, IR_resret#94363743, annual_retnet#94363745, std_retnet... [3624065] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624066 [labelType="html" label="MapPartitionsRDD [3624066]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624067 [labelType="html" label="MapPartitionsRDD [3624067]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624068 [labelType="html" label="MapPartitionsRDD [3624068]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301902 {
label="CollectLimit";
3624069 [labelType="html" label="MapPartitionsRDD [3624069]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301926 {
label="mapPartitionsInternal";
3624070 [labelType="html" label="MapPartitionsRDD [3624070]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301927 {
label="map";
3624071 [labelType="html" label="MapPartitionsRDD [3624071]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624055->3624056;
3624056->3624057;
3624057->3624058;
3624058->3624059;
3624059->3624060;
3624060->3624061;
3624061->3624062;
3624062->3624063;
3624063->3624064;
3624064->3624065;
3624065->3624066;
3624066->3624067;
3624067->3624068;
3624068->3624069;
3624069->3624070;
3624070->3624071;
}
3624059
3624065