digraph G {
subgraph clusterstage_512910 {
label="Stage 512910";
subgraph cluster6301335 {
label="Scan csv ";
3623713 [labelType="html" label="FileScanRDD [3623713]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623715 [labelType="html" label="MapPartitionsRDD [3623715]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301304 {
label="WholeStageCodegen (1)";
3623717 [labelType="html" label="MapPartitionsRDD [3623717]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301303 {
label="InMemoryTableScan";
3623718 [labelType="html" label="MapPartitionsRDD [3623718]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623721 [labelType="html" label="*(1) Project [CASE WHEN ((year#94356965 = NA) OR (year#94356965 = null)) THEN null ELSE cast(year#94356965 as float) END AS year#94357164, CASE WHEN ((retIC#94356966 = NA) OR (retIC#94356966 = null)) THEN null ELSE cast(retIC#94356966 as float) END AS retIC#94357166, CASE WHEN ((resretIC#94356967 = NA) OR (resretIC#94356967 = null)) THEN null ELSE cast(resretIC#94356967 as float) END AS resretIC#94357168, CASE WHEN ((numcos#94356968 = NA) OR (numcos#94356968 = null)) THEN null ELSE cast(numcos#94356968 as float) END AS numcos#94357170, CASE WHEN ((numdates#94356969 = NA) OR (numdates#94356969 = null)) THEN null ELSE cast(numdates#94356969 as int) END AS numdates#94357172, CASE WHEN (annual_bmret#94356970 = null) THEN null ELSE annual_bmret#94356970 END AS annual_bmret#94357173, CASE WHEN ((annual_ret#94356971 = NA) OR (annual_ret#94356971 = null)) THEN null ELSE cast(annual_ret#94356971 as float) END AS annual_ret#94357175, CASE WHEN ((std_ret#94356972 = NA) OR (std_ret#94356972 = null)) THEN null ELSE cas... [3623721] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623723 [labelType="html" label="MapPartitionsRDD [3623723]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623724 [labelType="html" label="MapPartitionsRDD [3623724]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623725 [labelType="html" label="MapPartitionsRDD [3623725]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301273 {
label="WholeStageCodegen (1)";
3623726 [labelType="html" label="MapPartitionsRDD [3623726]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301272 {
label="Exchange";
3623754 [labelType="html" label="MapPartitionsRDD [3623754]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623713->3623715;
3623715->3623717;
3623717->3623718;
3623718->3623721;
3623721->3623723;
3623723->3623724;
3623724->3623725;
3623725->3623726;
3623726->3623754;
}