digraph G {
subgraph clusterstage_512870 {
label="Stage 512870";
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"];
}
subgraph cluster6300855 {
label="InMemoryTableScan";
3623441 [labelType="html" label="MapPartitionsRDD [3623441]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623442 [labelType="html" label="MapPartitionsRDD [3623442]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623443 [labelType="html" label="MapPartitionsRDD [3623443]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300854 {
label="Exchange";
3623447 [labelType="html" label="MapPartitionsRDD [3623447]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623394->3623395;
3623395->3623396;
3623396->3623397;
3623397->3623398;
3623398->3623441;
3623441->3623442;
3623442->3623443;
3623443->3623447;
}