digraph G {
subgraph clusterstage_512570 {
label="Stage 512570";
subgraph cluster6297017 {
label="Scan csv ";
3621228 [labelType="html" label="FileScanRDD [3621228]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621229 [labelType="html" label="MapPartitionsRDD [3621229]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297014 {
label="WholeStageCodegen (1)";
3621230 [labelType="html" label="MapPartitionsRDD [3621230]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297013 {
label="InMemoryTableScan";
3621231 [labelType="html" label="MapPartitionsRDD [3621231]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621232 [labelType="html" label="*(1) Project [CASE WHEN (date#94290984 = null) THEN null ELSE cast(date#94290984 as date) END AS date#94291102, CASE WHEN ((allret#94290985 = NA) OR (allret#94290985 = null)) THEN null ELSE cast(allret#94290985 as float) END AS allret#94291108, CASE WHEN ((allcum#94290986 = NA) OR (allcum#94290986 = null)) THEN null ELSE cast(allcum#94290986 as float) END AS allcum#94291109, CASE WHEN ((drawdown_gross#94290987 = NA) OR (drawdown_gross#94290987 = null)) THEN null ELSE cast(drawdown_gross#94290987 as float) END AS drawdown_gross#94291110, CASE WHEN ((drawdown_length_gross#94290988 = NA) OR (drawdown_length_gross#94290988 = null)) THEN null ELSE cast(drawdown_length_gross#94290988 as int) END AS drawdown_length_gross#94291116, CASE WHEN ((allretnet#94290989 = NA) OR (allretnet#94290989 = null)) THEN null ELSE cast(allretnet#94290989 as float) END AS allretnet#94291122, CASE WHEN ((allcumnet#94290990 = NA) OR (allcumnet#94290990 = null)) THEN null ELSE cast(allcumnet#94290990 as float) END AS allcumnet#9429112... [3621232] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297057 {
label="InMemoryTableScan";
3621254 [labelType="html" label="MapPartitionsRDD [3621254]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621255 [labelType="html" label="MapPartitionsRDD [3621255]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621256 [labelType="html" label="MapPartitionsRDD [3621256]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297054 {
label="WholeStageCodegen (1)";
3621257 [labelType="html" label="MapPartitionsRDD [3621257]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297053 {
label="Exchange";
3621261 [labelType="html" label="MapPartitionsRDD [3621261]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621228->3621229;
3621229->3621230;
3621230->3621231;
3621231->3621232;
3621232->3621254;
3621254->3621255;
3621255->3621256;
3621256->3621257;
3621257->3621261;
}