digraph G {
subgraph clusterstage_512492 {
label="Stage 512492";
subgraph cluster6296084 {
label="Scan csv ";
3620691 [labelType="html" label="FileScanRDD [3620691]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620692 [labelType="html" label="MapPartitionsRDD [3620692]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296081 {
label="WholeStageCodegen (1)";
3620693 [labelType="html" label="MapPartitionsRDD [3620693]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296080 {
label="InMemoryTableScan";
3620694 [labelType="html" label="MapPartitionsRDD [3620694]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620695 [labelType="html" label="*(1) Project [CASE WHEN (date#94277187 = null) THEN null ELSE cast(date#94277187 as date) END AS date#94277363, CASE WHEN ((allret#94277188 = NA) OR (allret#94277188 = null)) THEN null ELSE cast(allret#94277188 as float) END AS allret#94277368, CASE WHEN ((allcum#94277189 = NA) OR (allcum#94277189 = null)) THEN null ELSE cast(allcum#94277189 as float) END AS allcum#94277369, CASE WHEN ((drawdown_gross#94277190 = NA) OR (drawdown_gross#94277190 = null)) THEN null ELSE cast(drawdown_gross#94277190 as float) END AS drawdown_gross#94277393, CASE WHEN ((drawdown_length_gross#94277191 = NA) OR (drawdown_length_gross#94277191 = null)) THEN null ELSE cast(drawdown_length_gross#94277191 as int) END AS drawdown_length_gross#94277394, CASE WHEN ((allretnet#94277192 = NA) OR (allretnet#94277192 = null)) THEN null ELSE cast(allretnet#94277192 as float) END AS allretnet#94277398, CASE WHEN ((allcumnet#94277193 = NA) OR (allcumnet#94277193 = null)) THEN null ELSE cast(allcumnet#94277193 as float) END AS allcumnet#9427740... [3620695] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620696 [labelType="html" label="MapPartitionsRDD [3620696]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620697 [labelType="html" label="MapPartitionsRDD [3620697]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620698 [labelType="html" label="MapPartitionsRDD [3620698]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296077 {
label="WholeStageCodegen (1)";
3620699 [labelType="html" label="MapPartitionsRDD [3620699]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296076 {
label="Exchange";
3620703 [labelType="html" label="MapPartitionsRDD [3620703]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620691->3620692;
3620692->3620693;
3620693->3620694;
3620694->3620695;
3620695->3620696;
3620696->3620697;
3620697->3620698;
3620698->3620699;
3620699->3620703;
}