digraph G {
subgraph clusterstage_512862 {
label="Stage 512862";
subgraph cluster6300782 {
label="Scan csv ";
3623394 [labelType="html" label="FileScanRDD [3623394]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623395 [labelType="html" label="MapPartitionsRDD [3623395]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300779 {
label="WholeStageCodegen (1)";
3623396 [labelType="html" label="MapPartitionsRDD [3623396]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300778 {
label="InMemoryTableScan";
3623397 [labelType="html" label="MapPartitionsRDD [3623397]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623398 [labelType="html" label="*(1) Project [CASE WHEN (date#94348290 = null) THEN null ELSE cast(date#94348290 as date) END AS date#94348458, CASE WHEN ((allret#94348291 = NA) OR (allret#94348291 = null)) THEN null ELSE cast(allret#94348291 as float) END AS allret#94348464, CASE WHEN ((allcum#94348292 = NA) OR (allcum#94348292 = null)) THEN null ELSE cast(allcum#94348292 as float) END AS allcum#94348470, CASE WHEN ((drawdown_gross#94348293 = NA) OR (drawdown_gross#94348293 = null)) THEN null ELSE cast(drawdown_gross#94348293 as float) END AS drawdown_gross#94348471, CASE WHEN ((drawdown_length_gross#94348294 = NA) OR (drawdown_length_gross#94348294 = null)) THEN null ELSE cast(drawdown_length_gross#94348294 as int) END AS drawdown_length_gross#94348477, CASE WHEN ((allretnet#94348295 = NA) OR (allretnet#94348295 = null)) THEN null ELSE cast(allretnet#94348295 as float) END AS allretnet#94348479, CASE WHEN ((allcumnet#94348296 = NA) OR (allcumnet#94348296 = null)) THEN null ELSE cast(allcumnet#94348296 as float) END AS allcumnet#9434850... [3623398] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623399 [labelType="html" label="MapPartitionsRDD [3623399]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623400 [labelType="html" label="MapPartitionsRDD [3623400]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623401 [labelType="html" label="MapPartitionsRDD [3623401]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300775 {
label="WholeStageCodegen (1)";
3623402 [labelType="html" label="MapPartitionsRDD [3623402]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300774 {
label="Exchange";
3623406 [labelType="html" label="MapPartitionsRDD [3623406]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623394->3623395;
3623395->3623396;
3623396->3623397;
3623397->3623398;
3623398->3623399;
3623399->3623400;
3623400->3623401;
3623401->3623402;
3623402->3623406;
}