digraph G {
subgraph clusterstage_513149 {
label="Stage 513149";
subgraph cluster6304393 {
label="Scan csv ";
3625460 [labelType="html" label="FileScanRDD [3625460]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625461 [labelType="html" label="MapPartitionsRDD [3625461]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304390 {
label="WholeStageCodegen (1)";
3625462 [labelType="html" label="MapPartitionsRDD [3625462]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304389 {
label="InMemoryTableScan";
3625463 [labelType="html" label="MapPartitionsRDD [3625463]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625464 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94399229 = NA) OR (overall#94399229 = null)) THEN null ELSE cast(overall#94399229 as int) END AS overall#94399417, CASE WHEN ((cap#94399230 = NA) OR (cap#94399230 = null)) THEN null ELSE cast(cap#94399230 as float) END AS cap#94399419, CASE WHEN ((retIC#94399231 = NA) OR (retIC#94399231 = null)) THEN null ELSE cast(retIC#94399231 as float) END AS retIC#94399421, CASE WHEN ((resretIC#94399232 = NA) OR (resretIC#94399232 = null)) THEN null ELSE cast(resretIC#94399232 as float) END AS resretIC#94399424, CASE WHEN ((size#94399233 = NA) OR (size#94399233 = null)) THEN null ELSE cast(size#94399233 as float) END AS size#94399425, CASE WHEN ((value#94399234 = NA) OR (value#94399234 = null)) THEN null ELSE cast(value#94399234 as float) END AS value#94399428, CASE WHEN ((growth#94399235 = NA) OR (growth#94399235 = null)) THEN null ELSE cast(growth#94399235 as float) END AS growth#94399429, CASE WHEN ((leverage#94399236 = NA) OR (leverage#94399236 = null)) THEN null ELSE cast(leverag... [3625464] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625465 [labelType="html" label="MapPartitionsRDD [3625465]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625466 [labelType="html" label="MapPartitionsRDD [3625466]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625467 [labelType="html" label="MapPartitionsRDD [3625467]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304384 {
label="WholeStageCodegen (1)";
3625468 [labelType="html" label="MapPartitionsRDD [3625468]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304383 {
label="InMemoryTableScan";
3625469 [labelType="html" label="MapPartitionsRDD [3625469]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625470 [labelType="html" label="*(1) Project [yield#94399438, volatility#94399433, momentum#94399435, size#94399425, value#94399428, growth#94399429, leverage#94399431]\n+- *(1) Filter (isnotnull(cap#94399419) AND (cap#94399419 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94399419, growth#94399429, leverage#94399431, momentum#94399435, size#94399425, value#94399428, volatility#94399433, yield#94399438], [isnotnull(cap#94399419), (cap#94399419 = 0.0)]\n +- InMemoryRelation [overall#94399417, cap#94399419, retIC#94399421, resretIC#94399424, size#94399425, value#94399428, growth#94399429, leverage#94399431, volatility#94399433, momentum#94399435, yield#94399438, numcos#94399440, numdates#94399441, annual_bmret#94399444, annual_ret#94399445, std_ret#94399448, Sharpe_ret#94399449, PctPos_ret#94399452, TR_ret#94399454, IR_ret#94399455, annual_resret#94399456, std_resret#94399457, Sharpe_resret#94399458, PctPos_resret#94399459, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3625470] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625471 [labelType="html" label="MapPartitionsRDD [3625471]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625472 [labelType="html" label="MapPartitionsRDD [3625472]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625473 [labelType="html" label="MapPartitionsRDD [3625473]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304380 {
label="WholeStageCodegen (1)";
3625474 [labelType="html" label="MapPartitionsRDD [3625474]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304379 {
label="CollectLimit";
3625475 [labelType="html" label="MapPartitionsRDD [3625475]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304394 {
label="mapPartitionsInternal";
3625476 [labelType="html" label="MapPartitionsRDD [3625476]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304395 {
label="map";
3625477 [labelType="html" label="MapPartitionsRDD [3625477]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625460->3625461;
3625461->3625462;
3625462->3625463;
3625463->3625464;
3625464->3625465;
3625465->3625466;
3625466->3625467;
3625467->3625468;
3625468->3625469;
3625469->3625470;
3625470->3625471;
3625471->3625472;
3625472->3625473;
3625473->3625474;
3625474->3625475;
3625475->3625476;
3625476->3625477;
}
3625464
3625470