digraph G {
subgraph clusterstage_512500 {
label="Stage 512500";
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 cluster6296157 {
label="InMemoryTableScan";
3620738 [labelType="html" label="MapPartitionsRDD [3620738]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620739 [labelType="html" label="MapPartitionsRDD [3620739]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620740 [labelType="html" label="MapPartitionsRDD [3620740]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6296156 {
label="Exchange";
3620744 [labelType="html" label="MapPartitionsRDD [3620744]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620691->3620692;
3620692->3620693;
3620693->3620694;
3620694->3620695;
3620695->3620738;
3620738->3620739;
3620739->3620740;
3620740->3620744;
}