digraph G {
subgraph clusterstage_512853 {
label="Stage 512853";
subgraph cluster6300656 {
label="Scan csv ";
3623306 [labelType="html" label="FileScanRDD [3623306]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623307 [labelType="html" label="MapPartitionsRDD [3623307]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300653 {
label="WholeStageCodegen (1)";
3623308 [labelType="html" label="MapPartitionsRDD [3623308]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300652 {
label="InMemoryTableScan";
3623309 [labelType="html" label="MapPartitionsRDD [3623309]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623310 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94342721 = NA) OR (overall#94342721 = null)) THEN null ELSE cast(overall#94342721 as int) END AS overall#94342864, CASE WHEN ((cap#94342722 = NA) OR (cap#94342722 = null)) THEN null ELSE cast(cap#94342722 as float) END AS cap#94342865, CASE WHEN ((retIC#94342723 = NA) OR (retIC#94342723 = null)) THEN null ELSE cast(retIC#94342723 as float) END AS retIC#94342866, CASE WHEN ((resretIC#94342724 = NA) OR (resretIC#94342724 = null)) THEN null ELSE cast(resretIC#94342724 as float) END AS resretIC#94342867, CASE WHEN ((size#94342725 = NA) OR (size#94342725 = null)) THEN null ELSE cast(size#94342725 as float) END AS size#94342868, CASE WHEN ((value#94342726 = NA) OR (value#94342726 = null)) THEN null ELSE cast(value#94342726 as float) END AS value#94342869, CASE WHEN ((growth#94342727 = NA) OR (growth#94342727 = null)) THEN null ELSE cast(growth#94342727 as float) END AS growth#94342870, CASE WHEN ((leverage#94342728 = NA) OR (leverage#94342728 = null)) THEN null ELSE cast(leverag... [3623310] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623311 [labelType="html" label="MapPartitionsRDD [3623311]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623312 [labelType="html" label="MapPartitionsRDD [3623312]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623313 [labelType="html" label="MapPartitionsRDD [3623313]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300647 {
label="WholeStageCodegen (1)";
3623314 [labelType="html" label="MapPartitionsRDD [3623314]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300646 {
label="InMemoryTableScan";
3623315 [labelType="html" label="MapPartitionsRDD [3623315]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623316 [labelType="html" label="*(1) Project [yield#94342874, volatility#94342872, momentum#94342873, size#94342868, value#94342869, growth#94342870, leverage#94342871]\n+- *(1) Filter (isnotnull(cap#94342865) AND (cap#94342865 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94342865, growth#94342870, leverage#94342871, momentum#94342873, size#94342868, value#94342869, volatility#94342872, yield#94342874], [isnotnull(cap#94342865), (cap#94342865 = 0.0)]\n +- InMemoryRelation [overall#94342864, cap#94342865, retIC#94342866, resretIC#94342867, size#94342868, value#94342869, growth#94342870, leverage#94342871, volatility#94342872, momentum#94342873, yield#94342874, numcos#94342875, numdates#94342876, annual_bmret#94342902, annual_ret#94342903, std_ret#94342904, Sharpe_ret#94342905, PctPos_ret#94342906, TR_ret#94342907, IR_ret#94342909, annual_resret#94342910, std_resret#94342911, Sharpe_resret#94342912, PctPos_resret#94342913, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3623316] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623317 [labelType="html" label="MapPartitionsRDD [3623317]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623318 [labelType="html" label="MapPartitionsRDD [3623318]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623319 [labelType="html" label="MapPartitionsRDD [3623319]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300643 {
label="WholeStageCodegen (1)";
3623320 [labelType="html" label="MapPartitionsRDD [3623320]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300642 {
label="CollectLimit";
3623321 [labelType="html" label="MapPartitionsRDD [3623321]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300657 {
label="mapPartitionsInternal";
3623322 [labelType="html" label="MapPartitionsRDD [3623322]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300658 {
label="map";
3623323 [labelType="html" label="MapPartitionsRDD [3623323]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623306->3623307;
3623307->3623308;
3623308->3623309;
3623309->3623310;
3623310->3623311;
3623311->3623312;
3623312->3623313;
3623313->3623314;
3623314->3623315;
3623315->3623316;
3623316->3623317;
3623317->3623318;
3623318->3623319;
3623319->3623320;
3623320->3623321;
3623321->3623322;
3623322->3623323;
}
3623310
3623316