digraph G {
subgraph clusterstage_512526 {
label="Stage 512526";
subgraph cluster6296492 {
label="Scan csv ";
3620928 [labelType="html" label="FileScanRDD [3620928]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620929 [labelType="html" label="MapPartitionsRDD [3620929]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296489 {
label="WholeStageCodegen (1)";
3620930 [labelType="html" label="MapPartitionsRDD [3620930]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296488 {
label="InMemoryTableScan";
3620931 [labelType="html" label="MapPartitionsRDD [3620931]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620932 [labelType="html" label="*(1) Project [CASE WHEN (date#94282340 = null) THEN null ELSE cast(date#94282340 as date) END AS date#94282656, CASE WHEN ((overall#94282341 = NA) OR (overall#94282341 = null)) THEN null ELSE cast(overall#94282341 as int) END AS overall#94282662, CASE WHEN ((ret#94282342 = NA) OR (ret#94282342 = null)) THEN null ELSE cast(ret#94282342 as float) END AS ret#94282666, CASE WHEN ((resret#94282343 = NA) OR (resret#94282343 = null)) THEN null ELSE cast(resret#94282343 as float) END AS resret#94282668, CASE WHEN ((retnet#94282344 = NA) OR (retnet#94282344 = null)) THEN null ELSE cast(retnet#94282344 as float) END AS retnet#94282671, CASE WHEN ((turnover#94282345 = NA) OR (turnover#94282345 = null)) THEN null ELSE cast(turnover#94282345 as float) END AS turnover#94282675, CASE WHEN ((numcos#94282346 = NA) OR (numcos#94282346 = null)) THEN null ELSE cast(numcos#94282346 as float) END AS numcos#94282679, CASE WHEN ((benchmark#94282347 = NA) OR (benchmark#94282347 = null)) THEN null ELSE cast(benchmark#94282347 as fl... [3620932] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620933 [labelType="html" label="MapPartitionsRDD [3620933]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620934 [labelType="html" label="MapPartitionsRDD [3620934]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620935 [labelType="html" label="MapPartitionsRDD [3620935]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296501 {
label="Scan csv ";
3620936 [labelType="html" label="FileScanRDD [3620936]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620937 [labelType="html" label="MapPartitionsRDD [3620937]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296498 {
label="WholeStageCodegen (1)";
3620938 [labelType="html" label="MapPartitionsRDD [3620938]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296497 {
label="InMemoryTableScan";
3620939 [labelType="html" label="MapPartitionsRDD [3620939]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620940 [labelType="html" label="*(1) Project [CASE WHEN (date#94282421 = null) THEN null ELSE cast(date#94282421 as date) END AS date#94282548, CASE WHEN ((cap#94282422 = NA) OR (cap#94282422 = null)) THEN null ELSE cast(cap#94282422 as float) END AS cap#94282549, CASE WHEN ((ret#94282423 = NA) OR (ret#94282423 = null)) THEN null ELSE cast(ret#94282423 as float) END AS ret#94282602, CASE WHEN ((resret#94282424 = NA) OR (resret#94282424 = null)) THEN null ELSE cast(resret#94282424 as float) END AS resret#94282603, CASE WHEN ((retnet#94282425 = NA) OR (retnet#94282425 = null)) THEN null ELSE cast(retnet#94282425 as float) END AS retnet#94282615, CASE WHEN ((turnover#94282426 = NA) OR (turnover#94282426 = null)) THEN null ELSE cast(turnover#94282426 as float) END AS turnover#94282653, CASE WHEN ((numcos#94282427 = NA) OR (numcos#94282427 = null)) THEN null ELSE cast(numcos#94282427 as float) END AS numcos#94282655, CASE WHEN ((coverage#94282428 = NA) OR (coverage#94282428 = null)) THEN null ELSE cast(coverage#94282428 as float) END AS cover... [3620940] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620941 [labelType="html" label="MapPartitionsRDD [3620941]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620942 [labelType="html" label="MapPartitionsRDD [3620942]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620943 [labelType="html" label="MapPartitionsRDD [3620943]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296493 {
label="WholeStageCodegen (1)";
3620944 [labelType="html" label="MapPartitionsRDD [3620944]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296487 {
label="Union";
3620945 [labelType="html" label="UnionRDD [3620945]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296486 {
label="Exchange";
3620949 [labelType="html" label="MapPartitionsRDD [3620949]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620928->3620929;
3620929->3620930;
3620930->3620931;
3620931->3620932;
3620932->3620933;
3620933->3620934;
3620934->3620935;
3620936->3620937;
3620937->3620938;
3620938->3620939;
3620939->3620940;
3620940->3620941;
3620941->3620942;
3620942->3620943;
3620943->3620944;
3620935->3620945;
3620944->3620945;
3620945->3620949;
}