digraph G {
subgraph clusterstage_512600 {
label="Stage 512600";
subgraph cluster6297436 {
label="Scan csv ";
3621471 [labelType="html" label="FileScanRDD [3621471]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621472 [labelType="html" label="MapPartitionsRDD [3621472]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297433 {
label="WholeStageCodegen (1)";
3621473 [labelType="html" label="MapPartitionsRDD [3621473]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297432 {
label="InMemoryTableScan";
3621474 [labelType="html" label="MapPartitionsRDD [3621474]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621475 [labelType="html" label="*(1) Project [CASE WHEN (date#94296240 = null) THEN null ELSE cast(date#94296240 as date) END AS date#94296415, CASE WHEN ((overall#94296241 = NA) OR (overall#94296241 = null)) THEN null ELSE cast(overall#94296241 as int) END AS overall#94296416, CASE WHEN ((ret#94296242 = NA) OR (ret#94296242 = null)) THEN null ELSE cast(ret#94296242 as float) END AS ret#94296443, CASE WHEN ((resret#94296243 = NA) OR (resret#94296243 = null)) THEN null ELSE cast(resret#94296243 as float) END AS resret#94296444, CASE WHEN ((retnet#94296244 = NA) OR (retnet#94296244 = null)) THEN null ELSE cast(retnet#94296244 as float) END AS retnet#94296445, CASE WHEN ((turnover#94296245 = NA) OR (turnover#94296245 = null)) THEN null ELSE cast(turnover#94296245 as float) END AS turnover#94296472, CASE WHEN ((numcos#94296246 = NA) OR (numcos#94296246 = null)) THEN null ELSE cast(numcos#94296246 as float) END AS numcos#94296473, CASE WHEN ((benchmark#94296247 = NA) OR (benchmark#94296247 = null)) THEN null ELSE cast(benchmark#94296247 as fl... [3621475] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621476 [labelType="html" label="MapPartitionsRDD [3621476]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621477 [labelType="html" label="MapPartitionsRDD [3621477]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621478 [labelType="html" label="MapPartitionsRDD [3621478]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297445 {
label="Scan csv ";
3621479 [labelType="html" label="FileScanRDD [3621479]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621480 [labelType="html" label="MapPartitionsRDD [3621480]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297442 {
label="WholeStageCodegen (1)";
3621481 [labelType="html" label="MapPartitionsRDD [3621481]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297441 {
label="InMemoryTableScan";
3621482 [labelType="html" label="MapPartitionsRDD [3621482]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621483 [labelType="html" label="*(1) Project [CASE WHEN (date#94296317 = null) THEN null ELSE cast(date#94296317 as date) END AS date#94296504, CASE WHEN ((cap#94296318 = NA) OR (cap#94296318 = null)) THEN null ELSE cast(cap#94296318 as float) END AS cap#94296521, CASE WHEN ((ret#94296319 = NA) OR (ret#94296319 = null)) THEN null ELSE cast(ret#94296319 as float) END AS ret#94296523, CASE WHEN ((resret#94296320 = NA) OR (resret#94296320 = null)) THEN null ELSE cast(resret#94296320 as float) END AS resret#94296525, CASE WHEN ((retnet#94296321 = NA) OR (retnet#94296321 = null)) THEN null ELSE cast(retnet#94296321 as float) END AS retnet#94296527, CASE WHEN ((turnover#94296322 = NA) OR (turnover#94296322 = null)) THEN null ELSE cast(turnover#94296322 as float) END AS turnover#94296529, CASE WHEN ((numcos#94296323 = NA) OR (numcos#94296323 = null)) THEN null ELSE cast(numcos#94296323 as float) END AS numcos#94296531, CASE WHEN ((coverage#94296324 = NA) OR (coverage#94296324 = null)) THEN null ELSE cast(coverage#94296324 as float) END AS cover... [3621483] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621484 [labelType="html" label="MapPartitionsRDD [3621484]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621485 [labelType="html" label="MapPartitionsRDD [3621485]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621486 [labelType="html" label="MapPartitionsRDD [3621486]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297437 {
label="WholeStageCodegen (1)";
3621487 [labelType="html" label="MapPartitionsRDD [3621487]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297431 {
label="Union";
3621488 [labelType="html" label="UnionRDD [3621488]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297430 {
label="Exchange";
3621492 [labelType="html" label="MapPartitionsRDD [3621492]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621471->3621472;
3621472->3621473;
3621473->3621474;
3621474->3621475;
3621475->3621476;
3621476->3621477;
3621477->3621478;
3621479->3621480;
3621480->3621481;
3621481->3621482;
3621482->3621483;
3621483->3621484;
3621484->3621485;
3621485->3621486;
3621486->3621487;
3621478->3621488;
3621487->3621488;
3621488->3621492;
}