digraph G {
subgraph clusterstage_513014 {
label="Stage 513014";
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 cluster6302693 {
label="InMemoryTableScan";
3624500 [labelType="html" label="MapPartitionsRDD [3624500]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624501 [labelType="html" label="MapPartitionsRDD [3624501]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624502 [labelType="html" label="MapPartitionsRDD [3624502]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302690 {
label="WholeStageCodegen (1)";
3624503 [labelType="html" label="MapPartitionsRDD [3624503]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302689 {
label="Exchange";
3624507 [labelType="html" label="MapPartitionsRDD [3624507]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624474->3624475;
3624475->3624476;
3624476->3624477;
3624477->3624478;
3624478->3624500;
3624500->3624501;
3624501->3624502;
3624502->3624503;
3624503->3624507;
}