digraph G {
subgraph clusterstage_512800 {
label="Stage 512800";
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 cluster6299946 {
label="InMemoryTableScan";
3622918 [labelType="html" label="MapPartitionsRDD [3622918]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622919 [labelType="html" label="MapPartitionsRDD [3622919]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622920 [labelType="html" label="MapPartitionsRDD [3622920]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299943 {
label="WholeStageCodegen (1)";
3622921 [labelType="html" label="MapPartitionsRDD [3622921]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299942 {
label="Exchange";
3622925 [labelType="html" label="MapPartitionsRDD [3622925]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622851->3622852;
3622852->3622853;
3622853->3622854;
3622854->3622855;
3622855->3622918;
3622918->3622919;
3622919->3622920;
3622920->3622921;
3622921->3622925;
}