digraph G {
subgraph clusterstage_512748 {
label="Stage 512748";
subgraph cluster6299313 {
label="Scan csv ";
3622551 [labelType="html" label="FileScanRDD [3622551]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622552 [labelType="html" label="MapPartitionsRDD [3622552]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299310 {
label="WholeStageCodegen (1)";
3622553 [labelType="html" label="MapPartitionsRDD [3622553]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299309 {
label="InMemoryTableScan";
3622554 [labelType="html" label="MapPartitionsRDD [3622554]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622555 [labelType="html" label="*(1) Project [CASE WHEN (date#94324581 = null) THEN null ELSE cast(date#94324581 as date) END AS date#94324653, CASE WHEN ((overall#94324582 = NA) OR (overall#94324582 = null)) THEN null ELSE cast(overall#94324582 as int) END AS overall#94324654, CASE WHEN ((ret#94324583 = NA) OR (ret#94324583 = null)) THEN null ELSE cast(ret#94324583 as float) END AS ret#94324655, CASE WHEN ((resret#94324584 = NA) OR (resret#94324584 = null)) THEN null ELSE cast(resret#94324584 as float) END AS resret#94324656, CASE WHEN ((retnet#94324585 = NA) OR (retnet#94324585 = null)) THEN null ELSE cast(retnet#94324585 as float) END AS retnet#94324683, CASE WHEN ((turnover#94324586 = NA) OR (turnover#94324586 = null)) THEN null ELSE cast(turnover#94324586 as float) END AS turnover#94324684, CASE WHEN ((numcos#94324587 = NA) OR (numcos#94324587 = null)) THEN null ELSE cast(numcos#94324587 as float) END AS numcos#94324711, CASE WHEN ((benchmark#94324588 = NA) OR (benchmark#94324588 = null)) THEN null ELSE cast(benchmark#94324588 as fl... [3622555] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622556 [labelType="html" label="MapPartitionsRDD [3622556]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622557 [labelType="html" label="MapPartitionsRDD [3622557]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622558 [labelType="html" label="MapPartitionsRDD [3622558]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299322 {
label="Scan csv ";
3622559 [labelType="html" label="FileScanRDD [3622559]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622560 [labelType="html" label="MapPartitionsRDD [3622560]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299319 {
label="WholeStageCodegen (1)";
3622561 [labelType="html" label="MapPartitionsRDD [3622561]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299318 {
label="InMemoryTableScan";
3622562 [labelType="html" label="MapPartitionsRDD [3622562]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622563 [labelType="html" label="*(1) Project [CASE WHEN (date#94324603 = null) THEN null ELSE cast(date#94324603 as date) END AS date#94324818, CASE WHEN ((cap#94324604 = NA) OR (cap#94324604 = null)) THEN null ELSE cast(cap#94324604 as float) END AS cap#94324845, CASE WHEN ((ret#94324605 = NA) OR (ret#94324605 = null)) THEN null ELSE cast(ret#94324605 as float) END AS ret#94324872, CASE WHEN ((resret#94324606 = NA) OR (resret#94324606 = null)) THEN null ELSE cast(resret#94324606 as float) END AS resret#94324873, CASE WHEN ((retnet#94324607 = NA) OR (retnet#94324607 = null)) THEN null ELSE cast(retnet#94324607 as float) END AS retnet#94324874, CASE WHEN ((turnover#94324608 = NA) OR (turnover#94324608 = null)) THEN null ELSE cast(turnover#94324608 as float) END AS turnover#94324902, CASE WHEN ((numcos#94324609 = NA) OR (numcos#94324609 = null)) THEN null ELSE cast(numcos#94324609 as float) END AS numcos#94324915, CASE WHEN ((coverage#94324610 = NA) OR (coverage#94324610 = null)) THEN null ELSE cast(coverage#94324610 as float) END AS cover... [3622563] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622564 [labelType="html" label="MapPartitionsRDD [3622564]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622565 [labelType="html" label="MapPartitionsRDD [3622565]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622566 [labelType="html" label="MapPartitionsRDD [3622566]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299314 {
label="WholeStageCodegen (1)";
3622567 [labelType="html" label="MapPartitionsRDD [3622567]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299308 {
label="Union";
3622568 [labelType="html" label="UnionRDD [3622568]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299307 {
label="Exchange";
3622572 [labelType="html" label="MapPartitionsRDD [3622572]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622551->3622552;
3622552->3622553;
3622553->3622554;
3622554->3622555;
3622555->3622556;
3622556->3622557;
3622557->3622558;
3622559->3622560;
3622560->3622561;
3622561->3622562;
3622562->3622563;
3622563->3622564;
3622564->3622565;
3622565->3622566;
3622566->3622567;
3622558->3622568;
3622567->3622568;
3622568->3622572;
}