digraph G {
subgraph clusterstage_512796 {
label="Stage 512796";
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 cluster6299911 {
label="InMemoryTableScan";
3622898 [labelType="html" label="MapPartitionsRDD [3622898]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622899 [labelType="html" label="MapPartitionsRDD [3622899]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622900 [labelType="html" label="MapPartitionsRDD [3622900]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299910 {
label="Exchange";
3622904 [labelType="html" label="MapPartitionsRDD [3622904]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622851->3622852;
3622852->3622853;
3622853->3622854;
3622854->3622855;
3622855->3622898;
3622898->3622899;
3622899->3622900;
3622900->3622904;
}