digraph G {
subgraph clusterstage_513058 {
label="Stage 513058";
subgraph cluster6303182 {
label="Scan csv ";
3624777 [labelType="html" label="FileScanRDD [3624777]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624779 [labelType="html" label="MapPartitionsRDD [3624779]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303151 {
label="WholeStageCodegen (1)";
3624782 [labelType="html" label="MapPartitionsRDD [3624782]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303150 {
label="InMemoryTableScan";
3624783 [labelType="html" label="MapPartitionsRDD [3624783]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624787 [labelType="html" label="*(1) Project [CASE WHEN ((year#94385350 = NA) OR (year#94385350 = null)) THEN null ELSE cast(year#94385350 as int) END AS year#94385518, CASE WHEN ((retIC#94385351 = NA) OR (retIC#94385351 = null)) THEN null ELSE cast(retIC#94385351 as float) END AS retIC#94385520, CASE WHEN ((resretIC#94385352 = NA) OR (resretIC#94385352 = null)) THEN null ELSE cast(resretIC#94385352 as float) END AS resretIC#94385523, CASE WHEN ((numcos#94385353 = NA) OR (numcos#94385353 = null)) THEN null ELSE cast(numcos#94385353 as float) END AS numcos#94385525, CASE WHEN ((numdates#94385354 = NA) OR (numdates#94385354 = null)) THEN null ELSE cast(numdates#94385354 as int) END AS numdates#94385527, CASE WHEN ((annual_bmret#94385355 = NA) OR (annual_bmret#94385355 = null)) THEN null ELSE cast(annual_bmret#94385355 as float) END AS annual_bmret#94385530, CASE WHEN ((annual_ret#94385356 = NA) OR (annual_ret#94385356 = null)) THEN null ELSE cast(annual_ret#94385356 as float) END AS annual_ret#94385532, CASE WHEN ((std_ret#94385357 = NA) O... [3624787] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624789 [labelType="html" label="MapPartitionsRDD [3624789]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624792 [labelType="html" label="MapPartitionsRDD [3624792]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624797 [labelType="html" label="MapPartitionsRDD [3624797]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303145 {
label="WholeStageCodegen (1)";
3624801 [labelType="html" label="MapPartitionsRDD [3624801]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303144 {
label="Exchange";
3624822 [labelType="html" label="MapPartitionsRDD [3624822]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624777->3624779;
3624779->3624782;
3624782->3624783;
3624783->3624787;
3624787->3624789;
3624789->3624792;
3624792->3624797;
3624797->3624801;
3624801->3624822;
}