digraph G {
subgraph clusterstage_512378 {
label="Stage 512378";
subgraph cluster6294626 {
label="Scan csv ";
3619854 [labelType="html" label="FileScanRDD [3619854]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619855 [labelType="html" label="MapPartitionsRDD [3619855]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294623 {
label="WholeStageCodegen (1)";
3619856 [labelType="html" label="MapPartitionsRDD [3619856]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294622 {
label="InMemoryTableScan";
3619857 [labelType="html" label="MapPartitionsRDD [3619857]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619858 [labelType="html" label="*(1) Project [CASE WHEN (date#94254675 = null) THEN null ELSE cast(date#94254675 as date) END AS date#94254826, CASE WHEN ((overall#94254676 = NA) OR (overall#94254676 = null)) THEN null ELSE cast(overall#94254676 as int) END AS overall#94254827, CASE WHEN ((ret#94254677 = NA) OR (ret#94254677 = null)) THEN null ELSE cast(ret#94254677 as float) END AS ret#94254828, CASE WHEN ((resret#94254678 = NA) OR (resret#94254678 = null)) THEN null ELSE cast(resret#94254678 as float) END AS resret#94254829, CASE WHEN ((retnet#94254679 = NA) OR (retnet#94254679 = null)) THEN null ELSE cast(retnet#94254679 as float) END AS retnet#94254830, CASE WHEN ((turnover#94254680 = NA) OR (turnover#94254680 = null)) THEN null ELSE cast(turnover#94254680 as float) END AS turnover#94254831, CASE WHEN ((numcos#94254681 = NA) OR (numcos#94254681 = null)) THEN null ELSE cast(numcos#94254681 as float) END AS numcos#94254832, CASE WHEN ((benchmark#94254682 = NA) OR (benchmark#94254682 = null)) THEN null ELSE cast(benchmark#94254682 as fl... [3619858] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619859 [labelType="html" label="MapPartitionsRDD [3619859]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619860 [labelType="html" label="MapPartitionsRDD [3619860]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619861 [labelType="html" label="MapPartitionsRDD [3619861]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294635 {
label="Scan csv ";
3619862 [labelType="html" label="FileScanRDD [3619862]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619863 [labelType="html" label="MapPartitionsRDD [3619863]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294632 {
label="WholeStageCodegen (1)";
3619864 [labelType="html" label="MapPartitionsRDD [3619864]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294631 {
label="InMemoryTableScan";
3619865 [labelType="html" label="MapPartitionsRDD [3619865]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619866 [labelType="html" label="*(1) Project [CASE WHEN (date#94254649 = null) THEN null ELSE cast(date#94254649 as date) END AS date#94254913, CASE WHEN ((cap#94254650 = NA) OR (cap#94254650 = null)) THEN null ELSE cast(cap#94254650 as float) END AS cap#94254914, CASE WHEN ((ret#94254651 = NA) OR (ret#94254651 = null)) THEN null ELSE cast(ret#94254651 as float) END AS ret#94254942, CASE WHEN ((resret#94254652 = NA) OR (resret#94254652 = null)) THEN null ELSE cast(resret#94254652 as float) END AS resret#94255044, CASE WHEN ((retnet#94254653 = NA) OR (retnet#94254653 = null)) THEN null ELSE cast(retnet#94254653 as float) END AS retnet#94255047, CASE WHEN ((turnover#94254654 = NA) OR (turnover#94254654 = null)) THEN null ELSE cast(turnover#94254654 as float) END AS turnover#94255050, CASE WHEN ((numcos#94254655 = NA) OR (numcos#94254655 = null)) THEN null ELSE cast(numcos#94254655 as float) END AS numcos#94255053, CASE WHEN ((coverage#94254656 = NA) OR (coverage#94254656 = null)) THEN null ELSE cast(coverage#94254656 as float) END AS cover... [3619866] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619867 [labelType="html" label="MapPartitionsRDD [3619867]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619868 [labelType="html" label="MapPartitionsRDD [3619868]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619869 [labelType="html" label="MapPartitionsRDD [3619869]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294627 {
label="WholeStageCodegen (1)";
3619870 [labelType="html" label="MapPartitionsRDD [3619870]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294621 {
label="Union";
3619871 [labelType="html" label="UnionRDD [3619871]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294620 {
label="Exchange";
3619875 [labelType="html" label="MapPartitionsRDD [3619875]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619854->3619855;
3619855->3619856;
3619856->3619857;
3619857->3619858;
3619858->3619859;
3619859->3619860;
3619860->3619861;
3619862->3619863;
3619863->3619864;
3619864->3619865;
3619865->3619866;
3619866->3619867;
3619867->3619868;
3619868->3619869;
3619869->3619870;
3619861->3619871;
3619870->3619871;
3619871->3619875;
}