digraph G {
subgraph clusterstage_512791 {
label="Stage 512791";
subgraph cluster6299838 {
label="Scan csv ";
3622851 [labelType="html" label="FileScanRDD [3622851]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622852 [labelType="html" label="MapPartitionsRDD [3622852]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299835 {
label="WholeStageCodegen (1)";
3622853 [labelType="html" label="MapPartitionsRDD [3622853]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299834 {
label="InMemoryTableScan";
3622854 [labelType="html" label="MapPartitionsRDD [3622854]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622855 [labelType="html" label="*(1) Project [CASE WHEN (date#94333860 = null) THEN null ELSE cast(date#94333860 as date) END AS date#94333951, CASE WHEN ((allret#94333861 = NA) OR (allret#94333861 = null)) THEN null ELSE cast(allret#94333861 as float) END AS allret#94333952, CASE WHEN ((allcum#94333862 = NA) OR (allcum#94333862 = null)) THEN null ELSE cast(allcum#94333862 as float) END AS allcum#94333953, CASE WHEN ((drawdown_gross#94333863 = NA) OR (drawdown_gross#94333863 = null)) THEN null ELSE cast(drawdown_gross#94333863 as float) END AS drawdown_gross#94333954, CASE WHEN ((drawdown_length_gross#94333864 = NA) OR (drawdown_length_gross#94333864 = null)) THEN null ELSE cast(drawdown_length_gross#94333864 as int) END AS drawdown_length_gross#94333955, CASE WHEN ((allretnet#94333865 = NA) OR (allretnet#94333865 = null)) THEN null ELSE cast(allretnet#94333865 as float) END AS allretnet#94333956, CASE WHEN ((allcumnet#94333866 = NA) OR (allcumnet#94333866 = null)) THEN null ELSE cast(allcumnet#94333866 as float) END AS allcumnet#9433395... [3622855] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299878 {
label="InMemoryTableScan";
3622877 [labelType="html" label="MapPartitionsRDD [3622877]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622878 [labelType="html" label="MapPartitionsRDD [3622878]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622879 [labelType="html" label="MapPartitionsRDD [3622879]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299875 {
label="WholeStageCodegen (1)";
3622880 [labelType="html" label="MapPartitionsRDD [3622880]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299874 {
label="Exchange";
3622881 [labelType="html" label="MapPartitionsRDD [3622881]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622882 [labelType="html" label="MapPartitionsRDD [3622882]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622883 [labelType="html" label="MapPartitionsRDD [3622883]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622851->3622852;
3622852->3622853;
3622853->3622854;
3622854->3622855;
3622855->3622877;
3622877->3622878;
3622878->3622879;
3622879->3622880;
3622880->3622881;
3622881->3622882;
3622882->3622883;
}