digraph G {
subgraph clusterstage_512833 {
label="Stage 512833";
subgraph cluster6300400 {
label="Scan csv ";
3623171 [labelType="html" label="FileScanRDD [3623171]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623172 [labelType="html" label="MapPartitionsRDD [3623172]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300356 {
label="WholeStageCodegen (1)";
3623173 [labelType="html" label="MapPartitionsRDD [3623173]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300355 {
label="InMemoryTableScan";
3623174 [labelType="html" label="MapPartitionsRDD [3623174]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623175 [labelType="html" label="*(1) Project [CASE WHEN ((year#94342605 = NA) OR (year#94342605 = null)) THEN null ELSE cast(year#94342605 as float) END AS year#94342706, CASE WHEN ((retIC#94342606 = NA) OR (retIC#94342606 = null)) THEN null ELSE cast(retIC#94342606 as float) END AS retIC#94342707, CASE WHEN ((resretIC#94342607 = NA) OR (resretIC#94342607 = null)) THEN null ELSE cast(resretIC#94342607 as float) END AS resretIC#94342708, CASE WHEN ((numcos#94342608 = NA) OR (numcos#94342608 = null)) THEN null ELSE cast(numcos#94342608 as float) END AS numcos#94342709, CASE WHEN ((numdates#94342609 = NA) OR (numdates#94342609 = null)) THEN null ELSE cast(numdates#94342609 as int) END AS numdates#94342710, CASE WHEN ((annual_bmret#94342610 = NA) OR (annual_bmret#94342610 = null)) THEN null ELSE cast(annual_bmret#94342610 as float) END AS annual_bmret#94342711, CASE WHEN ((annual_ret#94342611 = NA) OR (annual_ret#94342611 = null)) THEN null ELSE cast(annual_ret#94342611 as float) END AS annual_ret#94342712, CASE WHEN ((std_ret#94342612 = NA)... [3623175] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623176 [labelType="html" label="MapPartitionsRDD [3623176]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623177 [labelType="html" label="MapPartitionsRDD [3623177]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623178 [labelType="html" label="MapPartitionsRDD [3623178]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300350 {
label="WholeStageCodegen (1)";
3623179 [labelType="html" label="MapPartitionsRDD [3623179]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300349 {
label="Exchange";
3623203 [labelType="html" label="MapPartitionsRDD [3623203]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623171->3623172;
3623172->3623173;
3623173->3623174;
3623174->3623175;
3623175->3623176;
3623176->3623177;
3623177->3623178;
3623178->3623179;
3623179->3623203;
}