digraph G {
subgraph clusterstage_513009 {
label="Stage 513009";
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"];
3624479 [labelType="html" label="MapPartitionsRDD [3624479]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624480 [labelType="html" label="MapPartitionsRDD [3624480]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624481 [labelType="html" label="MapPartitionsRDD [3624481]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302646 {
label="WholeStageCodegen (1)";
3624482 [labelType="html" label="MapPartitionsRDD [3624482]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302645 {
label="Exchange";
3624483 [labelType="html" label="MapPartitionsRDD [3624483]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624484 [labelType="html" label="MapPartitionsRDD [3624484]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624485 [labelType="html" label="MapPartitionsRDD [3624485]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624474->3624475;
3624475->3624476;
3624476->3624477;
3624477->3624478;
3624478->3624479;
3624479->3624480;
3624480->3624481;
3624481->3624482;
3624482->3624483;
3624483->3624484;
3624484->3624485;
}