digraph G {
subgraph clusterstage_512304 {
label="Stage 512304";
subgraph cluster6293693 {
label="Scan csv ";
3619317 [labelType="html" label="FileScanRDD [3619317]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619318 [labelType="html" label="MapPartitionsRDD [3619318]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293690 {
label="WholeStageCodegen (1)";
3619319 [labelType="html" label="MapPartitionsRDD [3619319]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293689 {
label="InMemoryTableScan";
3619320 [labelType="html" label="MapPartitionsRDD [3619320]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619321 [labelType="html" label="*(1) Project [CASE WHEN (date#94240143 = null) THEN null ELSE cast(date#94240143 as date) END AS date#94240187, CASE WHEN ((overall#94240144 = NA) OR (overall#94240144 = null)) THEN null ELSE cast(overall#94240144 as int) END AS overall#94240188, CASE WHEN ((ret#94240145 = NA) OR (ret#94240145 = null)) THEN null ELSE cast(ret#94240145 as float) END AS ret#94240201, CASE WHEN ((resret#94240146 = NA) OR (resret#94240146 = null)) THEN null ELSE cast(resret#94240146 as float) END AS resret#94240203, CASE WHEN ((retnet#94240147 = NA) OR (retnet#94240147 = null)) THEN null ELSE cast(retnet#94240147 as float) END AS retnet#94240204, CASE WHEN ((turnover#94240148 = NA) OR (turnover#94240148 = null)) THEN null ELSE cast(turnover#94240148 as float) END AS turnover#94240205, CASE WHEN ((numcos#94240149 = NA) OR (numcos#94240149 = null)) THEN null ELSE cast(numcos#94240149 as float) END AS numcos#94240206, CASE WHEN ((benchmark#94240150 = NA) OR (benchmark#94240150 = null)) THEN null ELSE cast(benchmark#94240150 as fl... [3619321] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619322 [labelType="html" label="MapPartitionsRDD [3619322]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619323 [labelType="html" label="MapPartitionsRDD [3619323]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619324 [labelType="html" label="MapPartitionsRDD [3619324]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293702 {
label="Scan csv ";
3619325 [labelType="html" label="FileScanRDD [3619325]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619326 [labelType="html" label="MapPartitionsRDD [3619326]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293699 {
label="WholeStageCodegen (1)";
3619327 [labelType="html" label="MapPartitionsRDD [3619327]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293698 {
label="InMemoryTableScan";
3619328 [labelType="html" label="MapPartitionsRDD [3619328]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619329 [labelType="html" label="*(1) Project [CASE WHEN (date#94240082 = null) THEN null ELSE cast(date#94240082 as date) END AS date#94240130, CASE WHEN ((cap#94240083 = NA) OR (cap#94240083 = null)) THEN null ELSE cast(cap#94240083 as float) END AS cap#94240131, CASE WHEN ((ret#94240084 = NA) OR (ret#94240084 = null)) THEN null ELSE cast(ret#94240084 as float) END AS ret#94240132, CASE WHEN ((resret#94240085 = NA) OR (resret#94240085 = null)) THEN null ELSE cast(resret#94240085 as float) END AS resret#94240134, CASE WHEN ((retnet#94240086 = NA) OR (retnet#94240086 = null)) THEN null ELSE cast(retnet#94240086 as float) END AS retnet#94240135, CASE WHEN ((turnover#94240087 = NA) OR (turnover#94240087 = null)) THEN null ELSE cast(turnover#94240087 as float) END AS turnover#94240136, CASE WHEN ((numcos#94240088 = NA) OR (numcos#94240088 = null)) THEN null ELSE cast(numcos#94240088 as float) END AS numcos#94240137, CASE WHEN ((coverage#94240089 = NA) OR (coverage#94240089 = null)) THEN null ELSE cast(coverage#94240089 as float) END AS cover... [3619329] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619330 [labelType="html" label="MapPartitionsRDD [3619330]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619331 [labelType="html" label="MapPartitionsRDD [3619331]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619332 [labelType="html" label="MapPartitionsRDD [3619332]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293694 {
label="WholeStageCodegen (1)";
3619333 [labelType="html" label="MapPartitionsRDD [3619333]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293688 {
label="Union";
3619334 [labelType="html" label="UnionRDD [3619334]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6293687 {
label="Exchange";
3619338 [labelType="html" label="MapPartitionsRDD [3619338]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619317->3619318;
3619318->3619319;
3619319->3619320;
3619320->3619321;
3619321->3619322;
3619322->3619323;
3619323->3619324;
3619325->3619326;
3619326->3619327;
3619327->3619328;
3619328->3619329;
3619329->3619330;
3619330->3619331;
3619331->3619332;
3619332->3619333;
3619324->3619334;
3619333->3619334;
3619334->3619338;
}