digraph G {
subgraph clusterstage_513044 {
label="Stage 513044";
subgraph cluster6303061 {
label="Scan csv ";
3624711 [labelType="html" label="FileScanRDD [3624711]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624712 [labelType="html" label="MapPartitionsRDD [3624712]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303058 {
label="WholeStageCodegen (1)";
3624713 [labelType="html" label="MapPartitionsRDD [3624713]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303057 {
label="InMemoryTableScan";
3624714 [labelType="html" label="MapPartitionsRDD [3624714]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624715 [labelType="html" label="*(1) Project [CASE WHEN (date#94382301 = null) THEN null ELSE cast(date#94382301 as date) END AS date#94382484, CASE WHEN ((overall#94382302 = NA) OR (overall#94382302 = null)) THEN null ELSE cast(overall#94382302 as int) END AS overall#94382488, CASE WHEN ((ret#94382303 = NA) OR (ret#94382303 = null)) THEN null ELSE cast(ret#94382303 as float) END AS ret#94382490, CASE WHEN ((resret#94382304 = NA) OR (resret#94382304 = null)) THEN null ELSE cast(resret#94382304 as float) END AS resret#94382518, CASE WHEN ((retnet#94382305 = NA) OR (retnet#94382305 = null)) THEN null ELSE cast(retnet#94382305 as float) END AS retnet#94382519, CASE WHEN ((turnover#94382306 = NA) OR (turnover#94382306 = null)) THEN null ELSE cast(turnover#94382306 as float) END AS turnover#94382546, CASE WHEN ((numcos#94382307 = NA) OR (numcos#94382307 = null)) THEN null ELSE cast(numcos#94382307 as float) END AS numcos#94382547, CASE WHEN ((benchmark#94382308 = NA) OR (benchmark#94382308 = null)) THEN null ELSE cast(benchmark#94382308 as fl... [3624715] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624716 [labelType="html" label="MapPartitionsRDD [3624716]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624717 [labelType="html" label="MapPartitionsRDD [3624717]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624718 [labelType="html" label="MapPartitionsRDD [3624718]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303070 {
label="Scan csv ";
3624719 [labelType="html" label="FileScanRDD [3624719]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624720 [labelType="html" label="MapPartitionsRDD [3624720]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303067 {
label="WholeStageCodegen (1)";
3624721 [labelType="html" label="MapPartitionsRDD [3624721]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303066 {
label="InMemoryTableScan";
3624722 [labelType="html" label="MapPartitionsRDD [3624722]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624723 [labelType="html" label="*(1) Project [CASE WHEN (date#94382274 = null) THEN null ELSE cast(date#94382274 as date) END AS date#94382455, CASE WHEN ((cap#94382275 = NA) OR (cap#94382275 = null)) THEN null ELSE cast(cap#94382275 as float) END AS cap#94382456, CASE WHEN ((ret#94382276 = NA) OR (ret#94382276 = null)) THEN null ELSE cast(ret#94382276 as float) END AS ret#94382468, CASE WHEN ((resret#94382277 = NA) OR (resret#94382277 = null)) THEN null ELSE cast(resret#94382277 as float) END AS resret#94382469, CASE WHEN ((retnet#94382278 = NA) OR (retnet#94382278 = null)) THEN null ELSE cast(retnet#94382278 as float) END AS retnet#94382481, CASE WHEN ((turnover#94382279 = NA) OR (turnover#94382279 = null)) THEN null ELSE cast(turnover#94382279 as float) END AS turnover#94382482, CASE WHEN ((numcos#94382280 = NA) OR (numcos#94382280 = null)) THEN null ELSE cast(numcos#94382280 as float) END AS numcos#94382483, CASE WHEN ((coverage#94382281 = NA) OR (coverage#94382281 = null)) THEN null ELSE cast(coverage#94382281 as float) END AS cover... [3624723] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624724 [labelType="html" label="MapPartitionsRDD [3624724]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624725 [labelType="html" label="MapPartitionsRDD [3624725]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624726 [labelType="html" label="MapPartitionsRDD [3624726]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303062 {
label="WholeStageCodegen (1)";
3624727 [labelType="html" label="MapPartitionsRDD [3624727]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303056 {
label="Union";
3624728 [labelType="html" label="UnionRDD [3624728]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303055 {
label="Exchange";
3624732 [labelType="html" label="MapPartitionsRDD [3624732]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624711->3624712;
3624712->3624713;
3624713->3624714;
3624714->3624715;
3624715->3624716;
3624716->3624717;
3624717->3624718;
3624719->3624720;
3624720->3624721;
3624721->3624722;
3624722->3624723;
3624723->3624724;
3624724->3624725;
3624725->3624726;
3624726->3624727;
3624718->3624728;
3624727->3624728;
3624728->3624732;
}