digraph G {
subgraph clusterstage_512970 {
label="Stage 512970";
subgraph cluster6302128 {
label="Scan csv ";
3624174 [labelType="html" label="FileScanRDD [3624174]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624175 [labelType="html" label="MapPartitionsRDD [3624175]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302125 {
label="WholeStageCodegen (1)";
3624176 [labelType="html" label="MapPartitionsRDD [3624176]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302124 {
label="InMemoryTableScan";
3624177 [labelType="html" label="MapPartitionsRDD [3624177]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624178 [labelType="html" label="*(1) Project [CASE WHEN (date#94367711 = null) THEN null ELSE cast(date#94367711 as date) END AS date#94367886, CASE WHEN ((overall#94367712 = NA) OR (overall#94367712 = null)) THEN null ELSE cast(overall#94367712 as int) END AS overall#94367887, CASE WHEN ((ret#94367713 = NA) OR (ret#94367713 = null)) THEN null ELSE cast(ret#94367713 as float) END AS ret#94367888, CASE WHEN ((resret#94367714 = NA) OR (resret#94367714 = null)) THEN null ELSE cast(resret#94367714 as float) END AS resret#94367889, CASE WHEN ((retnet#94367715 = NA) OR (retnet#94367715 = null)) THEN null ELSE cast(retnet#94367715 as float) END AS retnet#94367890, CASE WHEN ((turnover#94367716 = NA) OR (turnover#94367716 = null)) THEN null ELSE cast(turnover#94367716 as float) END AS turnover#94367891, CASE WHEN ((numcos#94367717 = NA) OR (numcos#94367717 = null)) THEN null ELSE cast(numcos#94367717 as float) END AS numcos#94367892, CASE WHEN ((benchmark#94367718 = NA) OR (benchmark#94367718 = null)) THEN null ELSE cast(benchmark#94367718 as fl... [3624178] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624179 [labelType="html" label="MapPartitionsRDD [3624179]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624180 [labelType="html" label="MapPartitionsRDD [3624180]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624181 [labelType="html" label="MapPartitionsRDD [3624181]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302137 {
label="Scan csv ";
3624182 [labelType="html" label="FileScanRDD [3624182]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624183 [labelType="html" label="MapPartitionsRDD [3624183]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302134 {
label="WholeStageCodegen (1)";
3624184 [labelType="html" label="MapPartitionsRDD [3624184]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302133 {
label="InMemoryTableScan";
3624185 [labelType="html" label="MapPartitionsRDD [3624185]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624186 [labelType="html" label="*(1) Project [CASE WHEN (date#94367734 = null) THEN null ELSE cast(date#94367734 as date) END AS date#94368102, CASE WHEN ((cap#94367735 = NA) OR (cap#94367735 = null)) THEN null ELSE cast(cap#94367735 as float) END AS cap#94368103, CASE WHEN ((ret#94367736 = NA) OR (ret#94367736 = null)) THEN null ELSE cast(ret#94367736 as float) END AS ret#94368104, CASE WHEN ((resret#94367737 = NA) OR (resret#94367737 = null)) THEN null ELSE cast(resret#94367737 as float) END AS resret#94368123, CASE WHEN ((retnet#94367738 = NA) OR (retnet#94367738 = null)) THEN null ELSE cast(retnet#94367738 as float) END AS retnet#94368124, CASE WHEN ((turnover#94367739 = NA) OR (turnover#94367739 = null)) THEN null ELSE cast(turnover#94367739 as float) END AS turnover#94368125, CASE WHEN ((numcos#94367740 = NA) OR (numcos#94367740 = null)) THEN null ELSE cast(numcos#94367740 as float) END AS numcos#94368126, CASE WHEN ((coverage#94367741 = NA) OR (coverage#94367741 = null)) THEN null ELSE cast(coverage#94367741 as float) END AS cover... [3624186] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624187 [labelType="html" label="MapPartitionsRDD [3624187]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624188 [labelType="html" label="MapPartitionsRDD [3624188]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624189 [labelType="html" label="MapPartitionsRDD [3624189]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302129 {
label="WholeStageCodegen (1)";
3624190 [labelType="html" label="MapPartitionsRDD [3624190]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302123 {
label="Union";
3624191 [labelType="html" label="UnionRDD [3624191]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302122 {
label="Exchange";
3624195 [labelType="html" label="MapPartitionsRDD [3624195]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624174->3624175;
3624175->3624176;
3624176->3624177;
3624177->3624178;
3624178->3624179;
3624179->3624180;
3624180->3624181;
3624182->3624183;
3624183->3624184;
3624184->3624185;
3624185->3624186;
3624186->3624187;
3624187->3624188;
3624188->3624189;
3624189->3624190;
3624181->3624191;
3624190->3624191;
3624191->3624195;
}