digraph G {
subgraph clusterstage_512984 {
label="Stage 512984";
subgraph cluster6302271 {
label="Scan csv ";
3624251 [labelType="html" label="FileScanRDD [3624251]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624252 [labelType="html" label="MapPartitionsRDD [3624252]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302228 {
label="WholeStageCodegen (1)";
3624253 [labelType="html" label="MapPartitionsRDD [3624253]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302227 {
label="InMemoryTableScan";
3624254 [labelType="html" label="MapPartitionsRDD [3624254]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624255 [labelType="html" label="*(1) Project [CASE WHEN ((year#94371422 = NA) OR (year#94371422 = null)) THEN null ELSE cast(year#94371422 as int) END AS year#94371588, CASE WHEN ((retIC#94371423 = NA) OR (retIC#94371423 = null)) THEN null ELSE cast(retIC#94371423 as float) END AS retIC#94371589, CASE WHEN ((resretIC#94371424 = NA) OR (resretIC#94371424 = null)) THEN null ELSE cast(resretIC#94371424 as float) END AS resretIC#94371590, CASE WHEN ((numcos#94371425 = NA) OR (numcos#94371425 = null)) THEN null ELSE cast(numcos#94371425 as float) END AS numcos#94371624, CASE WHEN ((numdates#94371426 = NA) OR (numdates#94371426 = null)) THEN null ELSE cast(numdates#94371426 as int) END AS numdates#94371625, CASE WHEN ((annual_bmret#94371427 = NA) OR (annual_bmret#94371427 = null)) THEN null ELSE cast(annual_bmret#94371427 as float) END AS annual_bmret#94371626, CASE WHEN ((annual_ret#94371428 = NA) OR (annual_ret#94371428 = null)) THEN null ELSE cast(annual_ret#94371428 as float) END AS annual_ret#94371627, CASE WHEN ((std_ret#94371429 = NA) O... [3624255] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624256 [labelType="html" label="MapPartitionsRDD [3624256]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624257 [labelType="html" label="MapPartitionsRDD [3624257]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624258 [labelType="html" label="MapPartitionsRDD [3624258]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302222 {
label="WholeStageCodegen (1)";
3624259 [labelType="html" label="MapPartitionsRDD [3624259]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302221 {
label="Exchange";
3624297 [labelType="html" label="MapPartitionsRDD [3624297]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624251->3624252;
3624252->3624253;
3624253->3624254;
3624254->3624255;
3624255->3624256;
3624256->3624257;
3624257->3624258;
3624258->3624259;
3624259->3624297;
}