digraph G {
subgraph clusterstage_512896 {
label="Stage 512896";
subgraph cluster6301189 {
label="Scan csv ";
3623631 [labelType="html" label="FileScanRDD [3623631]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623632 [labelType="html" label="MapPartitionsRDD [3623632]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301186 {
label="WholeStageCodegen (1)";
3623633 [labelType="html" label="MapPartitionsRDD [3623633]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301185 {
label="InMemoryTableScan";
3623634 [labelType="html" label="MapPartitionsRDD [3623634]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623635 [labelType="html" label="*(1) Project [CASE WHEN (date#94353924 = null) THEN null ELSE cast(date#94353924 as date) END AS date#94354232, CASE WHEN ((overall#94353925 = NA) OR (overall#94353925 = null)) THEN null ELSE cast(overall#94353925 as int) END AS overall#94354233, CASE WHEN ((ret#94353926 = NA) OR (ret#94353926 = null)) THEN null ELSE cast(ret#94353926 as float) END AS ret#94354234, CASE WHEN ((resret#94353927 = NA) OR (resret#94353927 = null)) THEN null ELSE cast(resret#94353927 as float) END AS resret#94354235, CASE WHEN ((retnet#94353928 = NA) OR (retnet#94353928 = null)) THEN null ELSE cast(retnet#94353928 as float) END AS retnet#94354246, CASE WHEN ((turnover#94353929 = NA) OR (turnover#94353929 = null)) THEN null ELSE cast(turnover#94353929 as float) END AS turnover#94354247, CASE WHEN ((numcos#94353930 = NA) OR (numcos#94353930 = null)) THEN null ELSE cast(numcos#94353930 as float) END AS numcos#94354248, CASE WHEN (benchmark#94353931 = null) THEN null ELSE benchmark#94353931 END AS benchmark#94354249, CASE WHEN (exc... [3623635] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623636 [labelType="html" label="MapPartitionsRDD [3623636]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623637 [labelType="html" label="MapPartitionsRDD [3623637]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623638 [labelType="html" label="MapPartitionsRDD [3623638]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301198 {
label="Scan csv ";
3623639 [labelType="html" label="FileScanRDD [3623639]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623640 [labelType="html" label="MapPartitionsRDD [3623640]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301195 {
label="WholeStageCodegen (1)";
3623641 [labelType="html" label="MapPartitionsRDD [3623641]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301194 {
label="InMemoryTableScan";
3623642 [labelType="html" label="MapPartitionsRDD [3623642]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623643 [labelType="html" label="*(1) Project [CASE WHEN (date#94353948 = null) THEN null ELSE cast(date#94353948 as date) END AS date#94354207, CASE WHEN ((cap#94353949 = NA) OR (cap#94353949 = null)) THEN null ELSE cast(cap#94353949 as float) END AS cap#94354209, CASE WHEN ((ret#94353950 = NA) OR (ret#94353950 = null)) THEN null ELSE cast(ret#94353950 as float) END AS ret#94354245, CASE WHEN ((resret#94353951 = NA) OR (resret#94353951 = null)) THEN null ELSE cast(resret#94353951 as float) END AS resret#94354254, CASE WHEN ((retnet#94353952 = NA) OR (retnet#94353952 = null)) THEN null ELSE cast(retnet#94353952 as float) END AS retnet#94354255, CASE WHEN ((turnover#94353953 = NA) OR (turnover#94353953 = null)) THEN null ELSE cast(turnover#94353953 as float) END AS turnover#94354256, CASE WHEN ((numcos#94353954 = NA) OR (numcos#94353954 = null)) THEN null ELSE cast(numcos#94353954 as float) END AS numcos#94354257, CASE WHEN ((coverage#94353955 = NA) OR (coverage#94353955 = null)) THEN null ELSE cast(coverage#94353955 as float) END AS cover... [3623643] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623644 [labelType="html" label="MapPartitionsRDD [3623644]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623645 [labelType="html" label="MapPartitionsRDD [3623645]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623646 [labelType="html" label="MapPartitionsRDD [3623646]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301190 {
label="WholeStageCodegen (1)";
3623647 [labelType="html" label="MapPartitionsRDD [3623647]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301184 {
label="Union";
3623648 [labelType="html" label="UnionRDD [3623648]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301183 {
label="Exchange";
3623652 [labelType="html" label="MapPartitionsRDD [3623652]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623631->3623632;
3623632->3623633;
3623633->3623634;
3623634->3623635;
3623635->3623636;
3623636->3623637;
3623637->3623638;
3623639->3623640;
3623640->3623641;
3623641->3623642;
3623642->3623643;
3623643->3623644;
3623644->3623645;
3623645->3623646;
3623646->3623647;
3623638->3623648;
3623647->3623648;
3623648->3623652;
}