digraph G {
subgraph clusterstage_513132 {
label="Stage 513132";
subgraph cluster6304130 {
label="Scan csv ";
3625325 [labelType="html" label="FileScanRDD [3625325]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625326 [labelType="html" label="MapPartitionsRDD [3625326]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304097 {
label="WholeStageCodegen (1)";
3625327 [labelType="html" label="MapPartitionsRDD [3625327]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304096 {
label="InMemoryTableScan";
3625328 [labelType="html" label="MapPartitionsRDD [3625328]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625329 [labelType="html" label="*(1) Project [CASE WHEN ((year#94399178 = NA) OR (year#94399178 = null)) THEN null ELSE cast(year#94399178 as int) END AS year#94399378, CASE WHEN ((retIC#94399179 = NA) OR (retIC#94399179 = null)) THEN null ELSE cast(retIC#94399179 as float) END AS retIC#94399379, CASE WHEN ((resretIC#94399180 = NA) OR (resretIC#94399180 = null)) THEN null ELSE cast(resretIC#94399180 as float) END AS resretIC#94399413, CASE WHEN ((numcos#94399181 = NA) OR (numcos#94399181 = null)) THEN null ELSE cast(numcos#94399181 as float) END AS numcos#94399414, CASE WHEN ((numdates#94399182 = NA) OR (numdates#94399182 = null)) THEN null ELSE cast(numdates#94399182 as int) END AS numdates#94399415, CASE WHEN ((annual_bmret#94399183 = NA) OR (annual_bmret#94399183 = null)) THEN null ELSE cast(annual_bmret#94399183 as float) END AS annual_bmret#94399416, CASE WHEN ((annual_ret#94399184 = NA) OR (annual_ret#94399184 = null)) THEN null ELSE cast(annual_ret#94399184 as float) END AS annual_ret#94399418, CASE WHEN ((std_ret#94399185 = NA) O... [3625329] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625330 [labelType="html" label="MapPartitionsRDD [3625330]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625331 [labelType="html" label="MapPartitionsRDD [3625331]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625332 [labelType="html" label="MapPartitionsRDD [3625332]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304091 {
label="WholeStageCodegen (1)";
3625333 [labelType="html" label="MapPartitionsRDD [3625333]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304090 {
label="Exchange";
3625371 [labelType="html" label="MapPartitionsRDD [3625371]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625325->3625326;
3625326->3625327;
3625327->3625328;
3625328->3625329;
3625329->3625330;
3625330->3625331;
3625331->3625332;
3625332->3625333;
3625333->3625371;
}