digraph G {
subgraph clusterstage_512961 {
label="Stage 512961";
subgraph cluster6302027 {
label="Scan csv ";
3624117 [labelType="html" label="FileScanRDD [3624117]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624118 [labelType="html" label="MapPartitionsRDD [3624118]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302024 {
label="WholeStageCodegen (1)";
3624119 [labelType="html" label="MapPartitionsRDD [3624119]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302023 {
label="InMemoryTableScan";
3624120 [labelType="html" label="MapPartitionsRDD [3624120]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624121 [labelType="html" label="*(1) Project [CASE WHEN ((sector_id#94367759 = NA) OR (sector_id#94367759 = null)) THEN null ELSE cast(sector_id#94367759 as int) END AS sector_id#94368013, CASE WHEN ((retIC#94367760 = NA) OR (retIC#94367760 = null)) THEN null ELSE cast(retIC#94367760 as float) END AS retIC#94368015, CASE WHEN ((resretIC#94367761 = NA) OR (resretIC#94367761 = null)) THEN null ELSE cast(resretIC#94367761 as float) END AS resretIC#94368017, CASE WHEN ((numcos#94367762 = NA) OR (numcos#94367762 = null)) THEN null ELSE cast(numcos#94367762 as float) END AS numcos#94368019, CASE WHEN ((numdates#94367763 = NA) OR (numdates#94367763 = null)) THEN null ELSE cast(numdates#94367763 as int) END AS numdates#94368101, CASE WHEN ((annual_bmret#94367764 = NA) OR (annual_bmret#94367764 = null)) THEN null ELSE cast(annual_bmret#94367764 as float) END AS annual_bmret#94368107, CASE WHEN ((annual_ret#94367765 = NA) OR (annual_ret#94367765 = null)) THEN null ELSE cast(annual_ret#94367765 as float) END AS annual_ret#94368108, CASE WHEN ((std_... [3624121] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624122 [labelType="html" label="MapPartitionsRDD [3624122]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624123 [labelType="html" label="MapPartitionsRDD [3624123]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624124 [labelType="html" label="MapPartitionsRDD [3624124]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302007 {
label="WholeStageCodegen (2)";
3624125 [labelType="html" label="MapPartitionsRDD [3624125]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302006 {
label="Exchange";
3624129 [labelType="html" label="MapPartitionsRDD [3624129]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624117->3624118;
3624118->3624119;
3624119->3624120;
3624120->3624121;
3624121->3624122;
3624122->3624123;
3624123->3624124;
3624124->3624125;
3624125->3624129;
}