digraph G {
subgraph clusterstage_512822 {
label="Stage 512822";
subgraph cluster6300257 {
label="Scan csv ";
3623094 [labelType="html" label="FileScanRDD [3623094]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623095 [labelType="html" label="MapPartitionsRDD [3623095]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300254 {
label="WholeStageCodegen (1)";
3623096 [labelType="html" label="MapPartitionsRDD [3623096]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300253 {
label="InMemoryTableScan";
3623097 [labelType="html" label="MapPartitionsRDD [3623097]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623098 [labelType="html" label="*(1) Project [CASE WHEN (date#94338953 = null) THEN null ELSE cast(date#94338953 as date) END AS date#94339134, CASE WHEN ((overall#94338954 = NA) OR (overall#94338954 = null)) THEN null ELSE cast(overall#94338954 as int) END AS overall#94339136, CASE WHEN ((ret#94338955 = NA) OR (ret#94338955 = null)) THEN null ELSE cast(ret#94338955 as float) END AS ret#94339138, CASE WHEN ((resret#94338956 = NA) OR (resret#94338956 = null)) THEN null ELSE cast(resret#94338956 as float) END AS resret#94339166, CASE WHEN ((retnet#94338957 = NA) OR (retnet#94338957 = null)) THEN null ELSE cast(retnet#94338957 as float) END AS retnet#94339168, CASE WHEN ((turnover#94338958 = NA) OR (turnover#94338958 = null)) THEN null ELSE cast(turnover#94338958 as float) END AS turnover#94339196, CASE WHEN ((numcos#94338959 = NA) OR (numcos#94338959 = null)) THEN null ELSE cast(numcos#94338959 as float) END AS numcos#94339198, CASE WHEN ((benchmark#94338960 = NA) OR (benchmark#94338960 = null)) THEN null ELSE cast(benchmark#94338960 as fl... [3623098] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623099 [labelType="html" label="MapPartitionsRDD [3623099]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623100 [labelType="html" label="MapPartitionsRDD [3623100]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623101 [labelType="html" label="MapPartitionsRDD [3623101]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300266 {
label="Scan csv ";
3623102 [labelType="html" label="FileScanRDD [3623102]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623103 [labelType="html" label="MapPartitionsRDD [3623103]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300263 {
label="WholeStageCodegen (1)";
3623104 [labelType="html" label="MapPartitionsRDD [3623104]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300262 {
label="InMemoryTableScan";
3623105 [labelType="html" label="MapPartitionsRDD [3623105]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623106 [labelType="html" label="*(1) Project [CASE WHEN (date#94338925 = null) THEN null ELSE cast(date#94338925 as date) END AS date#94339106, CASE WHEN ((cap#94338926 = NA) OR (cap#94338926 = null)) THEN null ELSE cast(cap#94338926 as float) END AS cap#94339107, CASE WHEN ((ret#94338927 = NA) OR (ret#94338927 = null)) THEN null ELSE cast(ret#94338927 as float) END AS ret#94339108, CASE WHEN ((resret#94338928 = NA) OR (resret#94338928 = null)) THEN null ELSE cast(resret#94338928 as float) END AS resret#94339120, CASE WHEN ((retnet#94338929 = NA) OR (retnet#94338929 = null)) THEN null ELSE cast(retnet#94338929 as float) END AS retnet#94339121, CASE WHEN ((turnover#94338930 = NA) OR (turnover#94338930 = null)) THEN null ELSE cast(turnover#94338930 as float) END AS turnover#94339133, CASE WHEN ((numcos#94338931 = NA) OR (numcos#94338931 = null)) THEN null ELSE cast(numcos#94338931 as float) END AS numcos#94339135, CASE WHEN ((coverage#94338932 = NA) OR (coverage#94338932 = null)) THEN null ELSE cast(coverage#94338932 as float) END AS cover... [3623106] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623107 [labelType="html" label="MapPartitionsRDD [3623107]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623108 [labelType="html" label="MapPartitionsRDD [3623108]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623109 [labelType="html" label="MapPartitionsRDD [3623109]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300258 {
label="WholeStageCodegen (1)";
3623110 [labelType="html" label="MapPartitionsRDD [3623110]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300252 {
label="Union";
3623111 [labelType="html" label="UnionRDD [3623111]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300251 {
label="Exchange";
3623115 [labelType="html" label="MapPartitionsRDD [3623115]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623094->3623095;
3623095->3623096;
3623096->3623097;
3623097->3623098;
3623098->3623099;
3623099->3623100;
3623100->3623101;
3623102->3623103;
3623103->3623104;
3623104->3623105;
3623105->3623106;
3623106->3623107;
3623107->3623108;
3623108->3623109;
3623109->3623110;
3623101->3623111;
3623110->3623111;
3623111->3623115;
}