digraph G {
subgraph clusterstage_512223 {
label="Stage 512223";
subgraph cluster6292476 {
label="Scan csv ";
3618633 [labelType="html" label="FileScanRDD [3618633]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618634 [labelType="html" label="MapPartitionsRDD [3618634]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292473 {
label="WholeStageCodegen (1)";
3618635 [labelType="html" label="MapPartitionsRDD [3618635]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292472 {
label="InMemoryTableScan";
3618636 [labelType="html" label="MapPartitionsRDD [3618636]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618637 [labelType="html" label="*(1) Project [CASE WHEN (date#94225338 = null) THEN null ELSE cast(date#94225338 as date) END AS date#94225492, CASE WHEN ((allret#94225339 = NA) OR (allret#94225339 = null)) THEN null ELSE cast(allret#94225339 as float) END AS allret#94225493, CASE WHEN ((allcum#94225340 = NA) OR (allcum#94225340 = null)) THEN null ELSE cast(allcum#94225340 as float) END AS allcum#94225516, CASE WHEN ((drawdown_gross#94225341 = NA) OR (drawdown_gross#94225341 = null)) THEN null ELSE cast(drawdown_gross#94225341 as float) END AS drawdown_gross#94225517, CASE WHEN ((drawdown_length_gross#94225342 = NA) OR (drawdown_length_gross#94225342 = null)) THEN null ELSE cast(drawdown_length_gross#94225342 as int) END AS drawdown_length_gross#94225519, CASE WHEN ((allretnet#94225343 = NA) OR (allretnet#94225343 = null)) THEN null ELSE cast(allretnet#94225343 as float) END AS allretnet#94225521, CASE WHEN ((allcumnet#94225344 = NA) OR (allcumnet#94225344 = null)) THEN null ELSE cast(allcumnet#94225344 as float) END AS allcumnet#9422552... [3618637] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292620 {
label="InMemoryTableScan";
3618721 [labelType="html" label="MapPartitionsRDD [3618721]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618722 [labelType="html" label="MapPartitionsRDD [3618722]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618723 [labelType="html" label="MapPartitionsRDD [3618723]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292617 {
label="WholeStageCodegen (1)";
3618724 [labelType="html" label="MapPartitionsRDD [3618724]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292616 {
label="Exchange";
3618728 [labelType="html" label="MapPartitionsRDD [3618728]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3618633->3618634;
3618634->3618635;
3618635->3618636;
3618636->3618637;
3618637->3618721;
3618721->3618722;
3618722->3618723;
3618723->3618724;
3618724->3618728;
}