digraph G {
subgraph clusterstage_512219 {
label="Stage 512219";
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 cluster6292585 {
label="InMemoryTableScan";
3618701 [labelType="html" label="MapPartitionsRDD [3618701]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618702 [labelType="html" label="MapPartitionsRDD [3618702]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3618703 [labelType="html" label="MapPartitionsRDD [3618703]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6292584 {
label="Exchange";
3618707 [labelType="html" label="MapPartitionsRDD [3618707]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3618633->3618634;
3618634->3618635;
3618635->3618636;
3618636->3618637;
3618637->3618701;
3618701->3618702;
3618702->3618703;
3618703->3618707;
}