digraph G {
subgraph clusterstage_512806 {
label="Stage 512806";
subgraph cluster6300054 {
label="Scan csv ";
3622975 [labelType="html" label="FileScanRDD [3622975]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622976 [labelType="html" label="MapPartitionsRDD [3622976]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300051 {
label="WholeStageCodegen (1)";
3622977 [labelType="html" label="MapPartitionsRDD [3622977]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300050 {
label="InMemoryTableScan";
3622978 [labelType="html" label="MapPartitionsRDD [3622978]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622979 [labelType="html" label="*(1) Project [CASE WHEN (group#94334523 = null) THEN null ELSE group#94334523 END AS group#94334616, CASE WHEN ((annual_bmret#94334524 = NA) OR (annual_bmret#94334524 = null)) THEN null ELSE cast(annual_bmret#94334524 as float) END AS annual_bmret#94334617, CASE WHEN (annual_ret#94334525 = null) THEN null ELSE annual_ret#94334525 END AS annual_ret#94334618, CASE WHEN ((std_ret#94334526 = NA) OR (std_ret#94334526 = null)) THEN null ELSE cast(std_ret#94334526 as float) END AS std_ret#94334641, CASE WHEN ((Sharpe_ret#94334527 = NA) OR (Sharpe_ret#94334527 = null)) THEN null ELSE cast(Sharpe_ret#94334527 as float) END AS Sharpe_ret#94334664, CASE WHEN ((PctPos_ret#94334528 = NA) OR (PctPos_ret#94334528 = null)) THEN null ELSE cast(PctPos_ret#94334528 as float) END AS PctPos_ret#94334665, CASE WHEN ((TR_ret#94334529 = NA) OR (TR_ret#94334529 = null)) THEN null ELSE cast(TR_ret#94334529 as float) END AS TR_ret#94334666, CASE WHEN ((IR_ret#94334530 = NA) OR (IR_ret#94334530 = null)) THEN null ELSE cast(IR_ret#943... [3622979] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622980 [labelType="html" label="MapPartitionsRDD [3622980]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622981 [labelType="html" label="MapPartitionsRDD [3622981]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622982 [labelType="html" label="MapPartitionsRDD [3622982]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300033 {
label="WholeStageCodegen (2)";
3622983 [labelType="html" label="MapPartitionsRDD [3622983]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300032 {
label="InMemoryTableScan";
3622984 [labelType="html" label="MapPartitionsRDD [3622984]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622985 [labelType="html" label="*(2) Project [Category#94152530, Label#94152531, annual_ret#94334618, Sharpe_ret#94334664, PctPos_ret#94334665, annual_resret#94334668, Sharpe_resret#94334692, PctPos_resret#94334715, annual_retnet#94334851, Sharpe_retnet#94334877, PctPos_retnet#94334880]\n+- *(2) BroadcastHashJoin [group#94334616], [group#94152529], Inner, BuildRight, false\n :- *(2) Filter isnotnull(group#94334616)\n : +- InMemoryTableScan [group#94334616, annual_ret#94334618, Sharpe_ret#94334664, PctPos_ret#94334665, annual_resret#94334668, Sharpe_resret#94334692, PctPos_resret#94334715, annual_retnet#94334851, Sharpe_retnet#94334877, PctPos_retnet#94334880], [isnotnull(group#94334616)]\n : +- InMemoryRelation [group#94334616, annual_bmret#94334617, annual_ret#94334618, std_ret#94334641, Sharpe_ret#94334664, PctPos_ret#94334665, TR_ret#94334666, IR_ret#94334667, annual_resret#94334668, std_resret#94334691, Sharpe_resret#94334692, PctPos_resret#94334715, TR_resret#94334716, IR_resret#94334828, annual_retnet#94334851, std_retnet... [3622985] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622986 [labelType="html" label="MapPartitionsRDD [3622986]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622987 [labelType="html" label="MapPartitionsRDD [3622987]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622988 [labelType="html" label="MapPartitionsRDD [3622988]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300031 {
label="CollectLimit";
3622989 [labelType="html" label="MapPartitionsRDD [3622989]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300055 {
label="mapPartitionsInternal";
3622990 [labelType="html" label="MapPartitionsRDD [3622990]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300056 {
label="map";
3622991 [labelType="html" label="MapPartitionsRDD [3622991]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622975->3622976;
3622976->3622977;
3622977->3622978;
3622978->3622979;
3622979->3622980;
3622980->3622981;
3622981->3622982;
3622982->3622983;
3622983->3622984;
3622984->3622985;
3622985->3622986;
3622986->3622987;
3622987->3622988;
3622988->3622989;
3622989->3622990;
3622990->3622991;
}
3622979
3622985