digraph G {
subgraph clusterstage_512253 {
label="Stage 512253";
subgraph cluster6292952 {
label="Scan csv ";
3618911 [labelType="html" label="FileScanRDD [3618911]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618912 [labelType="html" label="MapPartitionsRDD [3618912]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292949 {
label="WholeStageCodegen (1)";
3618913 [labelType="html" label="MapPartitionsRDD [3618913]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292948 {
label="InMemoryTableScan";
3618914 [labelType="html" label="MapPartitionsRDD [3618914]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618915 [labelType="html" label="*(1) Project [CASE WHEN (date#94230794 = null) THEN null ELSE cast(date#94230794 as date) END AS date#94231100, CASE WHEN ((overall#94230795 = NA) OR (overall#94230795 = null)) THEN null ELSE cast(overall#94230795 as int) END AS overall#94231103, CASE WHEN ((ret#94230796 = NA) OR (ret#94230796 = null)) THEN null ELSE cast(ret#94230796 as float) END AS ret#94231107, CASE WHEN ((resret#94230797 = NA) OR (resret#94230797 = null)) THEN null ELSE cast(resret#94230797 as float) END AS resret#94231110, CASE WHEN ((retnet#94230798 = NA) OR (retnet#94230798 = null)) THEN null ELSE cast(retnet#94230798 as float) END AS retnet#94231115, CASE WHEN ((turnover#94230799 = NA) OR (turnover#94230799 = null)) THEN null ELSE cast(turnover#94230799 as float) END AS turnover#94231119, CASE WHEN ((numcos#94230800 = NA) OR (numcos#94230800 = null)) THEN null ELSE cast(numcos#94230800 as float) END AS numcos#94231122, CASE WHEN ((benchmark#94230801 = NA) OR (benchmark#94230801 = null)) THEN null ELSE cast(benchmark#94230801 as fl... [3618915] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618916 [labelType="html" label="MapPartitionsRDD [3618916]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618917 [labelType="html" label="MapPartitionsRDD [3618917]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618918 [labelType="html" label="MapPartitionsRDD [3618918]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292961 {
label="Scan csv ";
3618919 [labelType="html" label="FileScanRDD [3618919]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618920 [labelType="html" label="MapPartitionsRDD [3618920]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292958 {
label="WholeStageCodegen (1)";
3618921 [labelType="html" label="MapPartitionsRDD [3618921]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292957 {
label="InMemoryTableScan";
3618922 [labelType="html" label="MapPartitionsRDD [3618922]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618923 [labelType="html" label="*(1) Project [CASE WHEN (date#94230816 = null) THEN null ELSE cast(date#94230816 as date) END AS date#94231101, CASE WHEN ((cap#94230817 = NA) OR (cap#94230817 = null)) THEN null ELSE cast(cap#94230817 as float) END AS cap#94231104, CASE WHEN ((ret#94230818 = NA) OR (ret#94230818 = null)) THEN null ELSE cast(ret#94230818 as float) END AS ret#94231108, CASE WHEN ((resret#94230819 = NA) OR (resret#94230819 = null)) THEN null ELSE cast(resret#94230819 as float) END AS resret#94231112, CASE WHEN ((retnet#94230820 = NA) OR (retnet#94230820 = null)) THEN null ELSE cast(retnet#94230820 as float) END AS retnet#94231116, CASE WHEN ((turnover#94230821 = NA) OR (turnover#94230821 = null)) THEN null ELSE cast(turnover#94230821 as float) END AS turnover#94231120, CASE WHEN ((numcos#94230822 = NA) OR (numcos#94230822 = null)) THEN null ELSE cast(numcos#94230822 as float) END AS numcos#94231127, CASE WHEN ((coverage#94230823 = NA) OR (coverage#94230823 = null)) THEN null ELSE cast(coverage#94230823 as float) END AS cover... [3618923] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618924 [labelType="html" label="MapPartitionsRDD [3618924]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618925 [labelType="html" label="MapPartitionsRDD [3618925]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618926 [labelType="html" label="MapPartitionsRDD [3618926]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292953 {
label="WholeStageCodegen (1)";
3618927 [labelType="html" label="MapPartitionsRDD [3618927]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292947 {
label="Union";
3618928 [labelType="html" label="UnionRDD [3618928]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292946 {
label="Exchange";
3618953 [labelType="html" label="MapPartitionsRDD [3618953]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3618911->3618912;
3618912->3618913;
3618913->3618914;
3618914->3618915;
3618915->3618916;
3618916->3618917;
3618917->3618918;
3618919->3618920;
3618920->3618921;
3618921->3618922;
3618922->3618923;
3618923->3618924;
3618924->3618925;
3618925->3618926;
3618926->3618927;
3618918->3618928;
3618927->3618928;
3618928->3618953;
}