digraph G {
subgraph clusterstage_512504 {
label="Stage 512504";
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 cluster6296192 {
label="InMemoryTableScan";
3620758 [labelType="html" label="MapPartitionsRDD [3620758]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620759 [labelType="html" label="MapPartitionsRDD [3620759]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620760 [labelType="html" label="MapPartitionsRDD [3620760]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296189 {
label="WholeStageCodegen (1)";
3620761 [labelType="html" label="MapPartitionsRDD [3620761]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296188 {
label="Exchange";
3620765 [labelType="html" label="MapPartitionsRDD [3620765]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620691->3620692;
3620692->3620693;
3620693->3620694;
3620694->3620695;
3620695->3620758;
3620758->3620759;
3620759->3620760;
3620760->3620761;
3620761->3620765;
}