digraph G {
subgraph clusterstage_512927 {
label="Stage 512927";
subgraph cluster6301583 {
label="Scan csv ";
3623843 [labelType="html" label="FileScanRDD [3623843]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623844 [labelType="html" label="MapPartitionsRDD [3623844]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301580 {
label="WholeStageCodegen (1)";
3623845 [labelType="html" label="MapPartitionsRDD [3623845]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301579 {
label="InMemoryTableScan";
3623846 [labelType="html" label="MapPartitionsRDD [3623846]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623847 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94356932 = NA) OR (overall#94356932 = null)) THEN null ELSE cast(overall#94356932 as int) END AS overall#94357165, CASE WHEN ((cap#94356933 = NA) OR (cap#94356933 = null)) THEN null ELSE cast(cap#94356933 as float) END AS cap#94357167, CASE WHEN ((retIC#94356934 = NA) OR (retIC#94356934 = null)) THEN null ELSE cast(retIC#94356934 as float) END AS retIC#94357169, CASE WHEN ((resretIC#94356935 = NA) OR (resretIC#94356935 = null)) THEN null ELSE cast(resretIC#94356935 as float) END AS resretIC#94357171, CASE WHEN ((size#94356936 = NA) OR (size#94356936 = null)) THEN null ELSE cast(size#94356936 as float) END AS size#94357174, CASE WHEN ((value#94356937 = NA) OR (value#94356937 = null)) THEN null ELSE cast(value#94356937 as float) END AS value#94357176, CASE WHEN ((growth#94356938 = NA) OR (growth#94356938 = null)) THEN null ELSE cast(growth#94356938 as float) END AS growth#94357178, CASE WHEN ((leverage#94356939 = NA) OR (leverage#94356939 = null)) THEN null ELSE cast(leverag... [3623847] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623848 [labelType="html" label="MapPartitionsRDD [3623848]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623849 [labelType="html" label="MapPartitionsRDD [3623849]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623850 [labelType="html" label="MapPartitionsRDD [3623850]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301575 {
label="WholeStageCodegen (1)";
3623851 [labelType="html" label="MapPartitionsRDD [3623851]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301574 {
label="InMemoryTableScan";
3623852 [labelType="html" label="MapPartitionsRDD [3623852]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623853 [labelType="html" label="*(1) Project [yield#94357187, volatility#94357182, momentum#94357185, size#94357174, value#94357176, growth#94357178, leverage#94357180]\n+- *(1) Filter (isnotnull(cap#94357167) AND (cap#94357167 = 0.0))\n +- InMemoryTableScan [cap#94357167, growth#94357178, leverage#94357180, momentum#94357185, size#94357174, value#94357176, volatility#94357182, yield#94357187], [isnotnull(cap#94357167), (cap#94357167 = 0.0)]\n +- InMemoryRelation [overall#94357165, cap#94357167, retIC#94357169, resretIC#94357171, size#94357174, value#94357176, growth#94357178, leverage#94357180, volatility#94357182, momentum#94357185, yield#94357187, numcos#94357188, numdates#94357191, annual_bmret#94357192, annual_ret#94357194, std_ret#94357197, Sharpe_ret#94357199, PctPos_ret#94357201, TR_ret#94357203, IR_ret#94357204, annual_resret#94357207, std_resret#94357209, Sharpe_resret#94357211, PctPos_resret#94357212, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Project [CASE WHEN ((ove... [3623853] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623854 [labelType="html" label="MapPartitionsRDD [3623854]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623855 [labelType="html" label="MapPartitionsRDD [3623855]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623856 [labelType="html" label="MapPartitionsRDD [3623856]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301571 {
label="WholeStageCodegen (1)";
3623857 [labelType="html" label="MapPartitionsRDD [3623857]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301570 {
label="CollectLimit";
3623858 [labelType="html" label="MapPartitionsRDD [3623858]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301584 {
label="mapPartitionsInternal";
3623859 [labelType="html" label="MapPartitionsRDD [3623859]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301585 {
label="map";
3623860 [labelType="html" label="MapPartitionsRDD [3623860]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623843->3623844;
3623844->3623845;
3623845->3623846;
3623846->3623847;
3623847->3623848;
3623848->3623849;
3623849->3623850;
3623850->3623851;
3623851->3623852;
3623852->3623853;
3623853->3623854;
3623854->3623855;
3623855->3623856;
3623856->3623857;
3623857->3623858;
3623858->3623859;
3623859->3623860;
}
3623847
3623853