digraph G {
subgraph clusterstage_511809 {
label="Stage 511809";
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 cluster6287370 {
label="InMemoryTableScan";
3615675 [labelType="html" label="MapPartitionsRDD [3615675]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615676 [labelType="html" label="MapPartitionsRDD [3615676]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615677 [labelType="html" label="MapPartitionsRDD [3615677]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287366 {
label="WholeStageCodegen (1)";
3615678 [labelType="html" label="MapPartitionsRDD [3615678]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287365 {
label="InMemoryTableScan";
3615679 [labelType="html" label="MapPartitionsRDD [3615679]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615680 [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 = 3.0))\n +- InMemoryTableScan [cap#94014254, growth#94014265, leverage#94014267, momentum#94014271, size#94014260, value#94014263, volatility#94014269, yield#94014273], [isnotnull(cap#94014254), (cap#94014254 = 3.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... [3615680] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615681 [labelType="html" label="MapPartitionsRDD [3615681]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615682 [labelType="html" label="MapPartitionsRDD [3615682]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615683 [labelType="html" label="MapPartitionsRDD [3615683]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287362 {
label="WholeStageCodegen (1)";
3615684 [labelType="html" label="MapPartitionsRDD [3615684]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287361 {
label="CollectLimit";
3615685 [labelType="html" label="MapPartitionsRDD [3615685]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287371 {
label="mapPartitionsInternal";
3615686 [labelType="html" label="MapPartitionsRDD [3615686]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287372 {
label="map";
3615687 [labelType="html" label="MapPartitionsRDD [3615687]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610752->3610753;
3610753->3610754;
3610754->3610755;
3610755->3610756;
3610756->3615675;
3615675->3615676;
3615676->3615677;
3615677->3615678;
3615678->3615679;
3615679->3615680;
3615680->3615681;
3615681->3615682;
3615682->3615683;
3615683->3615684;
3615684->3615685;
3615685->3615686;
3615686->3615687;
}
3610756
3615680