digraph G {
subgraph clusterstage_513075 {
label="Stage 513075";
subgraph cluster6303460 {
label="Scan csv ";
3624923 [labelType="html" label="FileScanRDD [3624923]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624924 [labelType="html" label="MapPartitionsRDD [3624924]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303457 {
label="WholeStageCodegen (1)";
3624925 [labelType="html" label="MapPartitionsRDD [3624925]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303456 {
label="InMemoryTableScan";
3624926 [labelType="html" label="MapPartitionsRDD [3624926]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624927 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94385283 = NA) OR (overall#94385283 = null)) THEN null ELSE cast(overall#94385283 as int) END AS overall#94385516, CASE WHEN ((cap#94385284 = NA) OR (cap#94385284 = null)) THEN null ELSE cast(cap#94385284 as float) END AS cap#94385517, CASE WHEN ((retIC#94385285 = NA) OR (retIC#94385285 = null)) THEN null ELSE cast(retIC#94385285 as float) END AS retIC#94385519, CASE WHEN ((resretIC#94385286 = NA) OR (resretIC#94385286 = null)) THEN null ELSE cast(resretIC#94385286 as float) END AS resretIC#94385521, CASE WHEN ((size#94385287 = NA) OR (size#94385287 = null)) THEN null ELSE cast(size#94385287 as float) END AS size#94385522, CASE WHEN ((value#94385288 = NA) OR (value#94385288 = null)) THEN null ELSE cast(value#94385288 as float) END AS value#94385524, CASE WHEN ((growth#94385289 = NA) OR (growth#94385289 = null)) THEN null ELSE cast(growth#94385289 as float) END AS growth#94385526, CASE WHEN ((leverage#94385290 = NA) OR (leverage#94385290 = null)) THEN null ELSE cast(leverag... [3624927] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624928 [labelType="html" label="MapPartitionsRDD [3624928]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624929 [labelType="html" label="MapPartitionsRDD [3624929]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624930 [labelType="html" label="MapPartitionsRDD [3624930]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303451 {
label="WholeStageCodegen (1)";
3624931 [labelType="html" label="MapPartitionsRDD [3624931]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303450 {
label="InMemoryTableScan";
3624932 [labelType="html" label="MapPartitionsRDD [3624932]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624933 [labelType="html" label="*(1) Project [yield#94385533, volatility#94385529, momentum#94385531, size#94385522, value#94385524, growth#94385526, leverage#94385528]\n+- *(1) Filter (isnotnull(cap#94385517) AND (cap#94385517 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94385517, growth#94385526, leverage#94385528, momentum#94385531, size#94385522, value#94385524, volatility#94385529, yield#94385533], [isnotnull(cap#94385517), (cap#94385517 = 0.0)]\n +- InMemoryRelation [overall#94385516, cap#94385517, retIC#94385519, resretIC#94385521, size#94385522, value#94385524, growth#94385526, leverage#94385528, volatility#94385529, momentum#94385531, yield#94385533, numcos#94385535, numdates#94385537, annual_bmret#94385538, annual_ret#94385540, std_ret#94385542, Sharpe_ret#94385544, PctPos_ret#94385546, TR_ret#94385547, IR_ret#94385549, annual_resret#94385551, std_resret#94385553, Sharpe_resret#94385554, PctPos_resret#94385556, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3624933] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624934 [labelType="html" label="MapPartitionsRDD [3624934]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624935 [labelType="html" label="MapPartitionsRDD [3624935]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624936 [labelType="html" label="MapPartitionsRDD [3624936]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303447 {
label="WholeStageCodegen (1)";
3624937 [labelType="html" label="MapPartitionsRDD [3624937]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303446 {
label="CollectLimit";
3624938 [labelType="html" label="MapPartitionsRDD [3624938]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303461 {
label="mapPartitionsInternal";
3624939 [labelType="html" label="MapPartitionsRDD [3624939]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303462 {
label="map";
3624940 [labelType="html" label="MapPartitionsRDD [3624940]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624923->3624924;
3624924->3624925;
3624925->3624926;
3624926->3624927;
3624927->3624928;
3624928->3624929;
3624929->3624930;
3624930->3624931;
3624931->3624932;
3624932->3624933;
3624933->3624934;
3624934->3624935;
3624935->3624936;
3624936->3624937;
3624937->3624938;
3624938->3624939;
3624939->3624940;
}
3624927
3624933