digraph G {
subgraph clusterstage_512566 {
label="Stage 512566";
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"];
3621233 [labelType="html" label="MapPartitionsRDD [3621233]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621234 [labelType="html" label="MapPartitionsRDD [3621234]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621235 [labelType="html" label="MapPartitionsRDD [3621235]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297010 {
label="WholeStageCodegen (1)";
3621236 [labelType="html" label="MapPartitionsRDD [3621236]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297009 {
label="Exchange";
3621240 [labelType="html" label="MapPartitionsRDD [3621240]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621228->3621229;
3621229->3621230;
3621230->3621231;
3621231->3621232;
3621232->3621233;
3621233->3621234;
3621234->3621235;
3621235->3621236;
3621236->3621240;
}