digraph G {
subgraph clusterstage_512207 {
label="Stage 512207";
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"];
3618638 [labelType="html" label="MapPartitionsRDD [3618638]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618639 [labelType="html" label="MapPartitionsRDD [3618639]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618640 [labelType="html" label="MapPartitionsRDD [3618640]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292469 {
label="WholeStageCodegen (1)";
3618641 [labelType="html" label="MapPartitionsRDD [3618641]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292468 {
label="Exchange";
3618645 [labelType="html" label="MapPartitionsRDD [3618645]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3618633->3618634;
3618634->3618635;
3618635->3618636;
3618636->3618637;
3618637->3618638;
3618638->3618639;
3618639->3618640;
3618640->3618641;
3618641->3618645;
}