digraph G {
subgraph clusterstage_511681 {
label="Stage 511681";
subgraph cluster6286297 {
label="Scan csv ";
3615078 [labelType="html" label="FileScanRDD [3615078]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615079 [labelType="html" label="MapPartitionsRDD [3615079]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286294 {
label="WholeStageCodegen (1)";
3615080 [labelType="html" label="MapPartitionsRDD [3615080]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286293 {
label="InMemoryTableScan";
3615081 [labelType="html" label="MapPartitionsRDD [3615081]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615082 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94128830 = NA) OR (overall#94128830 = null)) THEN null ELSE cast(overall#94128830 as int) END AS overall#94129012, CASE WHEN ((cap#94128831 = NA) OR (cap#94128831 = null)) THEN null ELSE cast(cap#94128831 as float) END AS cap#94129014, CASE WHEN ((retIC#94128832 = NA) OR (retIC#94128832 = null)) THEN null ELSE cast(retIC#94128832 as float) END AS retIC#94129016, CASE WHEN ((resretIC#94128833 = NA) OR (resretIC#94128833 = null)) THEN null ELSE cast(resretIC#94128833 as float) END AS resretIC#94129018, CASE WHEN ((size#94128834 = NA) OR (size#94128834 = null)) THEN null ELSE cast(size#94128834 as float) END AS size#94129019, CASE WHEN ((value#94128835 = NA) OR (value#94128835 = null)) THEN null ELSE cast(value#94128835 as float) END AS value#94129021, CASE WHEN ((growth#94128836 = NA) OR (growth#94128836 = null)) THEN null ELSE cast(growth#94128836 as float) END AS growth#94129023, CASE WHEN ((leverage#94128837 = NA) OR (leverage#94128837 = null)) THEN null ELSE cast(leverag... [3615082] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615083 [labelType="html" label="MapPartitionsRDD [3615083]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615084 [labelType="html" label="MapPartitionsRDD [3615084]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615085 [labelType="html" label="MapPartitionsRDD [3615085]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286288 {
label="WholeStageCodegen (1)";
3615086 [labelType="html" label="MapPartitionsRDD [3615086]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286287 {
label="InMemoryTableScan";
3615087 [labelType="html" label="MapPartitionsRDD [3615087]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615088 [labelType="html" label="*(1) Project [yield#94129030, volatility#94129027, momentum#94129028, size#94129019, value#94129021, growth#94129023, leverage#94129025]\n+- *(1) Filter (isnotnull(cap#94129014) AND (cap#94129014 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94129014, growth#94129023, leverage#94129025, momentum#94129028, size#94129019, value#94129021, volatility#94129027, yield#94129030], [isnotnull(cap#94129014), (cap#94129014 = 0.0)]\n +- InMemoryRelation [overall#94129012, cap#94129014, retIC#94129016, resretIC#94129018, size#94129019, value#94129021, growth#94129023, leverage#94129025, volatility#94129027, momentum#94129028, yield#94129030, numcos#94129032, numdates#94129034, annual_bmret#94129036, annual_ret#94129037, std_ret#94129039, Sharpe_ret#94129041, PctPos_ret#94129042, TR_ret#94129044, IR_ret#94129046, annual_resret#94129048, std_resret#94129049, Sharpe_resret#94129051, PctPos_resret#94129053, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3615088] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615089 [labelType="html" label="MapPartitionsRDD [3615089]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615090 [labelType="html" label="MapPartitionsRDD [3615090]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615091 [labelType="html" label="MapPartitionsRDD [3615091]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286284 {
label="WholeStageCodegen (1)";
3615092 [labelType="html" label="MapPartitionsRDD [3615092]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286283 {
label="CollectLimit";
3615093 [labelType="html" label="MapPartitionsRDD [3615093]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286298 {
label="mapPartitionsInternal";
3615094 [labelType="html" label="MapPartitionsRDD [3615094]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286299 {
label="map";
3615095 [labelType="html" label="MapPartitionsRDD [3615095]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3615078->3615079;
3615079->3615080;
3615080->3615081;
3615081->3615082;
3615082->3615083;
3615083->3615084;
3615084->3615085;
3615085->3615086;
3615086->3615087;
3615087->3615088;
3615088->3615089;
3615089->3615090;
3615090->3615091;
3615091->3615092;
3615092->3615093;
3615093->3615094;
3615094->3615095;
}
3615082
3615088