digraph G {
subgraph clusterstage_512496 {
label="Stage 512496";
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"];
}
subgraph cluster6296124 {
label="InMemoryTableScan";
3620717 [labelType="html" label="MapPartitionsRDD [3620717]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620718 [labelType="html" label="MapPartitionsRDD [3620718]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620719 [labelType="html" label="MapPartitionsRDD [3620719]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296121 {
label="WholeStageCodegen (1)";
3620720 [labelType="html" label="MapPartitionsRDD [3620720]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296120 {
label="Exchange";
3620724 [labelType="html" label="MapPartitionsRDD [3620724]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620691->3620692;
3620692->3620693;
3620693->3620694;
3620694->3620695;
3620695->3620717;
3620717->3620718;
3620718->3620719;
3620719->3620720;
3620720->3620724;
}