digraph G {
subgraph clusterstage_511754 {
label="Stage 511754";
subgraph cluster6278778 {
label="Scan csv ";
3610752 [labelType="html" label="FileScanRDD [3610752]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610753 [labelType="html" label="MapPartitionsRDD [3610753]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278775 {
label="WholeStageCodegen (1)";
3610754 [labelType="html" label="MapPartitionsRDD [3610754]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278774 {
label="InMemoryTableScan";
3610755 [labelType="html" label="MapPartitionsRDD [3610755]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610756 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94014066 = NA) OR (overall#94014066 = null)) THEN null ELSE cast(overall#94014066 as int) END AS overall#94014252, CASE WHEN ((cap#94014067 = NA) OR (cap#94014067 = null)) THEN null ELSE cast(cap#94014067 as float) END AS cap#94014254, CASE WHEN ((retIC#94014068 = NA) OR (retIC#94014068 = null)) THEN null ELSE cast(retIC#94014068 as float) END AS retIC#94014256, CASE WHEN ((resretIC#94014069 = NA) OR (resretIC#94014069 = null)) THEN null ELSE cast(resretIC#94014069 as float) END AS resretIC#94014258, CASE WHEN ((size#94014070 = NA) OR (size#94014070 = null)) THEN null ELSE cast(size#94014070 as float) END AS size#94014260, CASE WHEN ((value#94014071 = NA) OR (value#94014071 = null)) THEN null ELSE cast(value#94014071 as float) END AS value#94014263, CASE WHEN ((growth#94014072 = NA) OR (growth#94014072 = null)) THEN null ELSE cast(growth#94014072 as float) END AS growth#94014265, CASE WHEN ((leverage#94014073 = NA) OR (leverage#94014073 = null)) THEN null ELSE cast(leverag... [3610756] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286852 {
label="InMemoryTableScan";
3615393 [labelType="html" label="MapPartitionsRDD [3615393]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615394 [labelType="html" label="MapPartitionsRDD [3615394]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615395 [labelType="html" label="MapPartitionsRDD [3615395]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286834 {
label="WholeStageCodegen (1)";
3615399 [labelType="html" label="MapPartitionsRDD [3615399]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286833 {
label="InMemoryTableScan";
3615400 [labelType="html" label="MapPartitionsRDD [3615400]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615402 [labelType="html" label="*(1) Project [yield#94014273, volatility#94014269, momentum#94014271, size#94014260, value#94014263, growth#94014265, leverage#94014267]\n+- *(1) Filter (isnotnull(cap#94014254) AND (cap#94014254 = 2.0))\n +- InMemoryTableScan [cap#94014254, growth#94014265, leverage#94014267, momentum#94014271, size#94014260, value#94014263, volatility#94014269, yield#94014273], [isnotnull(cap#94014254), (cap#94014254 = 2.0)]\n +- InMemoryRelation [overall#94014252, cap#94014254, retIC#94014256, resretIC#94014258, size#94014260, value#94014263, growth#94014265, leverage#94014267, volatility#94014269, momentum#94014271, yield#94014273, numcos#94014276, numdates#94014278, annual_bmret#94014280, annual_ret#94014282, std_ret#94014284, Sharpe_ret#94014286, PctPos_ret#94014288, TR_ret#94014290, IR_ret#94014291, annual_resret#94014293, std_resret#94014294, Sharpe_resret#94014295, PctPos_resret#94014296, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Project [CASE WHEN ((ove... [3615402] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615404 [labelType="html" label="MapPartitionsRDD [3615404]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615405 [labelType="html" label="MapPartitionsRDD [3615405]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615410 [labelType="html" label="MapPartitionsRDD [3615410]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286827 {
label="WholeStageCodegen (1)";
3615418 [labelType="html" label="MapPartitionsRDD [3615418]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286826 {
label="CollectLimit";
3615419 [labelType="html" label="MapPartitionsRDD [3615419]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286866 {
label="mapPartitionsInternal";
3615420 [labelType="html" label="MapPartitionsRDD [3615420]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286867 {
label="map";
3615421 [labelType="html" label="MapPartitionsRDD [3615421]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610752->3610753;
3610753->3610754;
3610754->3610755;
3610755->3610756;
3610756->3615393;
3615393->3615394;
3615394->3615395;
3615395->3615399;
3615399->3615400;
3615400->3615402;
3615402->3615404;
3615404->3615405;
3615405->3615410;
3615410->3615418;
3615418->3615419;
3615419->3615420;
3615420->3615421;
}
3610756
3615402