digraph G {
subgraph clusterstage_512452 {
label="Stage 512452";
subgraph cluster6295559 {
label="Scan csv ";
3620391 [labelType="html" label="FileScanRDD [3620391]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620392 [labelType="html" label="MapPartitionsRDD [3620392]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295556 {
label="WholeStageCodegen (1)";
3620393 [labelType="html" label="MapPartitionsRDD [3620393]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295555 {
label="InMemoryTableScan";
3620394 [labelType="html" label="MapPartitionsRDD [3620394]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620395 [labelType="html" label="*(1) Project [CASE WHEN (date#94267773 = null) THEN null ELSE cast(date#94267773 as date) END AS date#94268081, CASE WHEN ((overall#94267774 = NA) OR (overall#94267774 = null)) THEN null ELSE cast(overall#94267774 as int) END AS overall#94268086, CASE WHEN ((ret#94267775 = NA) OR (ret#94267775 = null)) THEN null ELSE cast(ret#94267775 as float) END AS ret#94268089, CASE WHEN ((resret#94267776 = NA) OR (resret#94267776 = null)) THEN null ELSE cast(resret#94267776 as float) END AS resret#94268092, CASE WHEN ((retnet#94267777 = NA) OR (retnet#94267777 = null)) THEN null ELSE cast(retnet#94267777 as float) END AS retnet#94268098, CASE WHEN ((turnover#94267778 = NA) OR (turnover#94267778 = null)) THEN null ELSE cast(turnover#94267778 as float) END AS turnover#94268102, CASE WHEN ((numcos#94267779 = NA) OR (numcos#94267779 = null)) THEN null ELSE cast(numcos#94267779 as float) END AS numcos#94268104, CASE WHEN ((benchmark#94267780 = NA) OR (benchmark#94267780 = null)) THEN null ELSE cast(benchmark#94267780 as fl... [3620395] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620396 [labelType="html" label="MapPartitionsRDD [3620396]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620397 [labelType="html" label="MapPartitionsRDD [3620397]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620398 [labelType="html" label="MapPartitionsRDD [3620398]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295568 {
label="Scan csv ";
3620399 [labelType="html" label="FileScanRDD [3620399]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620400 [labelType="html" label="MapPartitionsRDD [3620400]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295565 {
label="WholeStageCodegen (1)";
3620401 [labelType="html" label="MapPartitionsRDD [3620401]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295564 {
label="InMemoryTableScan";
3620402 [labelType="html" label="MapPartitionsRDD [3620402]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620403 [labelType="html" label="*(1) Project [CASE WHEN (date#94267801 = null) THEN null ELSE cast(date#94267801 as date) END AS date#94268082, CASE WHEN ((cap#94267802 = NA) OR (cap#94267802 = null)) THEN null ELSE cast(cap#94267802 as float) END AS cap#94268084, CASE WHEN ((ret#94267803 = NA) OR (ret#94267803 = null)) THEN null ELSE cast(ret#94267803 as float) END AS ret#94268088, CASE WHEN ((resret#94267804 = NA) OR (resret#94267804 = null)) THEN null ELSE cast(resret#94267804 as float) END AS resret#94268093, CASE WHEN ((retnet#94267805 = NA) OR (retnet#94267805 = null)) THEN null ELSE cast(retnet#94267805 as float) END AS retnet#94268097, CASE WHEN ((turnover#94267806 = NA) OR (turnover#94267806 = null)) THEN null ELSE cast(turnover#94267806 as float) END AS turnover#94268101, CASE WHEN ((numcos#94267807 = NA) OR (numcos#94267807 = null)) THEN null ELSE cast(numcos#94267807 as float) END AS numcos#94268106, CASE WHEN ((coverage#94267808 = NA) OR (coverage#94267808 = null)) THEN null ELSE cast(coverage#94267808 as float) END AS cover... [3620403] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620404 [labelType="html" label="MapPartitionsRDD [3620404]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620405 [labelType="html" label="MapPartitionsRDD [3620405]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620406 [labelType="html" label="MapPartitionsRDD [3620406]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295560 {
label="WholeStageCodegen (1)";
3620407 [labelType="html" label="MapPartitionsRDD [3620407]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295554 {
label="Union";
3620408 [labelType="html" label="UnionRDD [3620408]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295553 {
label="Exchange";
3620412 [labelType="html" label="MapPartitionsRDD [3620412]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620391->3620392;
3620392->3620393;
3620393->3620394;
3620394->3620395;
3620395->3620396;
3620396->3620397;
3620397->3620398;
3620399->3620400;
3620400->3620401;
3620401->3620402;
3620402->3620403;
3620403->3620404;
3620404->3620405;
3620405->3620406;
3620406->3620407;
3620398->3620408;
3620407->3620408;
3620408->3620412;
}