digraph G {
subgraph clusterstage_512779 {
label="Stage 512779";
subgraph cluster6299712 {
label="Scan csv ";
3622763 [labelType="html" label="FileScanRDD [3622763]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622764 [labelType="html" label="MapPartitionsRDD [3622764]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299709 {
label="WholeStageCodegen (1)";
3622765 [labelType="html" label="MapPartitionsRDD [3622765]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299708 {
label="InMemoryTableScan";
3622766 [labelType="html" label="MapPartitionsRDD [3622766]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622767 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94328261 = NA) OR (overall#94328261 = null)) THEN null ELSE cast(overall#94328261 as float) END AS overall#94328493, CASE WHEN ((cap#94328264 = NA) OR (cap#94328264 = null)) THEN null ELSE cast(cap#94328264 as float) END AS cap#94328495, CASE WHEN ((retIC#94328265 = NA) OR (retIC#94328265 = null)) THEN null ELSE cast(retIC#94328265 as float) END AS retIC#94328497, CASE WHEN ((resretIC#94328267 = NA) OR (resretIC#94328267 = null)) THEN null ELSE cast(resretIC#94328267 as float) END AS resretIC#94328499, CASE WHEN ((size#94328269 = NA) OR (size#94328269 = null)) THEN null ELSE cast(size#94328269 as float) END AS size#94328501, CASE WHEN ((value#94328272 = NA) OR (value#94328272 = null)) THEN null ELSE cast(value#94328272 as float) END AS value#94328503, CASE WHEN ((growth#94328273 = NA) OR (growth#94328273 = null)) THEN null ELSE cast(growth#94328273 as float) END AS growth#94328505, CASE WHEN ((leverage#94328275 = NA) OR (leverage#94328275 = null)) THEN null ELSE cast(lever... [3622767] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622768 [labelType="html" label="MapPartitionsRDD [3622768]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622769 [labelType="html" label="MapPartitionsRDD [3622769]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622770 [labelType="html" label="MapPartitionsRDD [3622770]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299703 {
label="WholeStageCodegen (1)";
3622771 [labelType="html" label="MapPartitionsRDD [3622771]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299702 {
label="InMemoryTableScan";
3622772 [labelType="html" label="MapPartitionsRDD [3622772]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622773 [labelType="html" label="*(1) Project [yield#94328513, volatility#94328509, momentum#94328511, size#94328501, value#94328503, growth#94328505, leverage#94328507]\n+- *(1) Filter (isnotnull(cap#94328495) AND (cap#94328495 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94328495, growth#94328505, leverage#94328507, momentum#94328511, size#94328501, value#94328503, volatility#94328509, yield#94328513], [isnotnull(cap#94328495), (cap#94328495 = 0.0)]\n +- InMemoryRelation [overall#94328493, cap#94328495, retIC#94328497, resretIC#94328499, size#94328501, value#94328503, growth#94328505, leverage#94328507, volatility#94328509, momentum#94328511, yield#94328513, numcos#94328515, numdates#94328517, annual_bmret#94328519, annual_ret#94328521, std_ret#94328523, Sharpe_ret#94328525, PctPos_ret#94328527, TR_ret#94328529, IR_ret#94328531, annual_resret#94328533, std_resret#94328535, Sharpe_resret#94328537, PctPos_resret#94328539, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3622773] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622774 [labelType="html" label="MapPartitionsRDD [3622774]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622775 [labelType="html" label="MapPartitionsRDD [3622775]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622776 [labelType="html" label="MapPartitionsRDD [3622776]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299699 {
label="WholeStageCodegen (1)";
3622777 [labelType="html" label="MapPartitionsRDD [3622777]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299698 {
label="CollectLimit";
3622778 [labelType="html" label="MapPartitionsRDD [3622778]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299713 {
label="mapPartitionsInternal";
3622779 [labelType="html" label="MapPartitionsRDD [3622779]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299714 {
label="map";
3622780 [labelType="html" label="MapPartitionsRDD [3622780]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622763->3622764;
3622764->3622765;
3622765->3622766;
3622766->3622767;
3622767->3622768;
3622768->3622769;
3622769->3622770;
3622770->3622771;
3622771->3622772;
3622772->3622773;
3622773->3622774;
3622774->3622775;
3622775->3622776;
3622776->3622777;
3622777->3622778;
3622778->3622779;
3622779->3622780;
}
3622767
3622773