digraph G {
subgraph clusterstage_512874 {
label="Stage 512874";
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 cluster6300890 {
label="InMemoryTableScan";
3623461 [labelType="html" label="MapPartitionsRDD [3623461]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623462 [labelType="html" label="MapPartitionsRDD [3623462]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623463 [labelType="html" label="MapPartitionsRDD [3623463]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300887 {
label="WholeStageCodegen (1)";
3623464 [labelType="html" label="MapPartitionsRDD [3623464]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300886 {
label="Exchange";
3623468 [labelType="html" label="MapPartitionsRDD [3623468]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623394->3623395;
3623395->3623396;
3623396->3623397;
3623397->3623398;
3623398->3623461;
3623461->3623462;
3623462->3623463;
3623463->3623464;
3623464->3623468;
}