digraph G {
subgraph clusterstage_512788 {
label="Stage 512788";
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"];
3622856 [labelType="html" label="MapPartitionsRDD [3622856]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622857 [labelType="html" label="MapPartitionsRDD [3622857]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622858 [labelType="html" label="MapPartitionsRDD [3622858]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299831 {
label="WholeStageCodegen (1)";
3622859 [labelType="html" label="MapPartitionsRDD [3622859]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299830 {
label="Exchange";
3622863 [labelType="html" label="MapPartitionsRDD [3622863]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622851->3622852;
3622852->3622853;
3622853->3622854;
3622854->3622855;
3622855->3622856;
3622856->3622857;
3622857->3622858;
3622858->3622859;
3622859->3622863;
}