digraph G {
subgraph clusterstage_513028 {
label="Stage 513028";
subgraph cluster6302869 {
label="Scan csv ";
3624598 [labelType="html" label="FileScanRDD [3624598]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624599 [labelType="html" label="MapPartitionsRDD [3624599]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302866 {
label="WholeStageCodegen (1)";
3624600 [labelType="html" label="MapPartitionsRDD [3624600]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302865 {
label="InMemoryTableScan";
3624601 [labelType="html" label="MapPartitionsRDD [3624601]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624602 [labelType="html" label="*(1) Project [CASE WHEN (group#94377982 = null) THEN null ELSE group#94377982 END AS group#94378122, CASE WHEN ((annual_bmret#94377983 = NA) OR (annual_bmret#94377983 = null)) THEN null ELSE cast(annual_bmret#94377983 as float) END AS annual_bmret#94378123, CASE WHEN ((annual_ret#94377984 = NA) OR (annual_ret#94377984 = null)) THEN null ELSE cast(annual_ret#94377984 as float) END AS annual_ret#94378124, CASE WHEN ((std_ret#94377985 = NA) OR (std_ret#94377985 = null)) THEN null ELSE cast(std_ret#94377985 as float) END AS std_ret#94378125, CASE WHEN ((Sharpe_ret#94377986 = NA) OR (Sharpe_ret#94377986 = null)) THEN null ELSE cast(Sharpe_ret#94377986 as float) END AS Sharpe_ret#94378126, CASE WHEN ((PctPos_ret#94377987 = NA) OR (PctPos_ret#94377987 = null)) THEN null ELSE cast(PctPos_ret#94377987 as float) END AS PctPos_ret#94378127, CASE WHEN ((TR_ret#94377988 = NA) OR (TR_ret#94377988 = null)) THEN null ELSE cast(TR_ret#94377988 as float) END AS TR_ret#94378128, CASE WHEN ((IR_ret#94377989 = NA) OR (IR_ret#9... [3624602] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624603 [labelType="html" label="MapPartitionsRDD [3624603]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624604 [labelType="html" label="MapPartitionsRDD [3624604]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624605 [labelType="html" label="MapPartitionsRDD [3624605]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302848 {
label="WholeStageCodegen (2)";
3624606 [labelType="html" label="MapPartitionsRDD [3624606]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302847 {
label="InMemoryTableScan";
3624607 [labelType="html" label="MapPartitionsRDD [3624607]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624608 [labelType="html" label="*(2) Project [Category#94152530, Label#94152531, annual_ret#94378124, Sharpe_ret#94378126, PctPos_ret#94378127, annual_resret#94378130, Sharpe_resret#94378132, PctPos_resret#94378133, annual_retnet#94378136, Sharpe_retnet#94378138, PctPos_retnet#94378139]\n+- *(2) BroadcastHashJoin [group#94378122], [group#94152529], Inner, BuildRight, false\n :- *(2) Filter isnotnull(group#94378122)\n : +- InMemoryTableScan [group#94378122, annual_ret#94378124, Sharpe_ret#94378126, PctPos_ret#94378127, annual_resret#94378130, Sharpe_resret#94378132, PctPos_resret#94378133, annual_retnet#94378136, Sharpe_retnet#94378138, PctPos_retnet#94378139], [isnotnull(group#94378122)]\n : +- InMemoryRelation [group#94378122, annual_bmret#94378123, annual_ret#94378124, std_ret#94378125, Sharpe_ret#94378126, PctPos_ret#94378127, TR_ret#94378128, IR_ret#94378129, annual_resret#94378130, std_resret#94378131, Sharpe_resret#94378132, PctPos_resret#94378133, TR_resret#94378134, IR_resret#94378135, annual_retnet#94378136, std_retnet... [3624608] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624609 [labelType="html" label="MapPartitionsRDD [3624609]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624610 [labelType="html" label="MapPartitionsRDD [3624610]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624611 [labelType="html" label="MapPartitionsRDD [3624611]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302846 {
label="CollectLimit";
3624612 [labelType="html" label="MapPartitionsRDD [3624612]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302870 {
label="mapPartitionsInternal";
3624613 [labelType="html" label="MapPartitionsRDD [3624613]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302871 {
label="map";
3624614 [labelType="html" label="MapPartitionsRDD [3624614]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624598->3624599;
3624599->3624600;
3624600->3624601;
3624601->3624602;
3624602->3624603;
3624603->3624604;
3624604->3624605;
3624605->3624606;
3624606->3624607;
3624607->3624608;
3624608->3624609;
3624609->3624610;
3624610->3624611;
3624611->3624612;
3624612->3624613;
3624613->3624614;
}
3624602
3624608