digraph G {
subgraph clusterstage_513018 {
label="Stage 513018";
subgraph cluster6302653 {
label="Scan csv ";
3624474 [labelType="html" label="FileScanRDD [3624474]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624475 [labelType="html" label="MapPartitionsRDD [3624475]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302650 {
label="WholeStageCodegen (1)";
3624476 [labelType="html" label="MapPartitionsRDD [3624476]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302649 {
label="InMemoryTableScan";
3624477 [labelType="html" label="MapPartitionsRDD [3624477]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624478 [labelType="html" label="*(1) Project [CASE WHEN (date#94377170 = null) THEN null ELSE cast(date#94377170 as date) END AS date#94377294, CASE WHEN ((allret#94377171 = NA) OR (allret#94377171 = null)) THEN null ELSE cast(allret#94377171 as float) END AS allret#94377300, CASE WHEN ((allcum#94377172 = NA) OR (allcum#94377172 = null)) THEN null ELSE cast(allcum#94377172 as float) END AS allcum#94377301, CASE WHEN ((drawdown_gross#94377173 = NA) OR (drawdown_gross#94377173 = null)) THEN null ELSE cast(drawdown_gross#94377173 as float) END AS drawdown_gross#94377307, CASE WHEN ((drawdown_length_gross#94377174 = NA) OR (drawdown_length_gross#94377174 = null)) THEN null ELSE cast(drawdown_length_gross#94377174 as int) END AS drawdown_length_gross#94377308, CASE WHEN ((allretnet#94377175 = NA) OR (allretnet#94377175 = null)) THEN null ELSE cast(allretnet#94377175 as float) END AS allretnet#94377314, CASE WHEN ((allcumnet#94377176 = NA) OR (allcumnet#94377176 = null)) THEN null ELSE cast(allcumnet#94377176 as float) END AS allcumnet#9437731... [3624478] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302726 {
label="InMemoryTableScan";
3624521 [labelType="html" label="MapPartitionsRDD [3624521]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624522 [labelType="html" label="MapPartitionsRDD [3624522]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624523 [labelType="html" label="MapPartitionsRDD [3624523]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302725 {
label="Exchange";
3624527 [labelType="html" label="MapPartitionsRDD [3624527]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624474->3624475;
3624475->3624476;
3624476->3624477;
3624477->3624478;
3624478->3624521;
3624521->3624522;
3624522->3624523;
3624523->3624527;
}