digraph G {
subgraph clusterstage_512578 {
label="Stage 512578";
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 cluster6297125 {
label="InMemoryTableScan";
3621295 [labelType="html" label="MapPartitionsRDD [3621295]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621296 [labelType="html" label="MapPartitionsRDD [3621296]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621297 [labelType="html" label="MapPartitionsRDD [3621297]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297122 {
label="WholeStageCodegen (1)";
3621298 [labelType="html" label="MapPartitionsRDD [3621298]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297121 {
label="Exchange";
3621302 [labelType="html" label="MapPartitionsRDD [3621302]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621228->3621229;
3621229->3621230;
3621230->3621231;
3621231->3621232;
3621232->3621295;
3621295->3621296;
3621296->3621297;
3621297->3621298;
3621298->3621302;
}