digraph G {
subgraph clusterstage_511710 {
label="Stage 511710";
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 cluster6286474 {
label="InMemoryTableScan";
3615186 [labelType="html" label="MapPartitionsRDD [3615186]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615187 [labelType="html" label="MapPartitionsRDD [3615187]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615188 [labelType="html" label="MapPartitionsRDD [3615188]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286447 {
label="WholeStageCodegen (1)";
3615189 [labelType="html" label="MapPartitionsRDD [3615189]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286446 {
label="InMemoryTableScan";
3615190 [labelType="html" label="MapPartitionsRDD [3615190]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615191 [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 = 1.0))\n +- InMemoryTableScan [cap#94014254, growth#94014265, leverage#94014267, momentum#94014271, size#94014260, value#94014263, volatility#94014269, yield#94014273], [isnotnull(cap#94014254), (cap#94014254 = 1.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... [3615191] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615192 [labelType="html" label="MapPartitionsRDD [3615192]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615195 [labelType="html" label="MapPartitionsRDD [3615195]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615197 [labelType="html" label="MapPartitionsRDD [3615197]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286443 {
label="WholeStageCodegen (1)";
3615204 [labelType="html" label="MapPartitionsRDD [3615204]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286442 {
label="CollectLimit";
3615210 [labelType="html" label="MapPartitionsRDD [3615210]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286491 {
label="mapPartitionsInternal";
3615211 [labelType="html" label="MapPartitionsRDD [3615211]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286492 {
label="map";
3615212 [labelType="html" label="MapPartitionsRDD [3615212]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610752->3610753;
3610753->3610754;
3610754->3610755;
3610755->3610756;
3610756->3615186;
3615186->3615187;
3615187->3615188;
3615188->3615189;
3615189->3615190;
3615190->3615191;
3615191->3615192;
3615192->3615195;
3615195->3615197;
3615197->3615204;
3615204->3615210;
3615210->3615211;
3615211->3615212;
}
3610756
3615191