digraph G {
subgraph clusterstage_512726 {
label="Stage 512726";
subgraph cluster6298894 {
label="Scan csv ";
3622308 [labelType="html" label="FileScanRDD [3622308]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622309 [labelType="html" label="MapPartitionsRDD [3622309]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298891 {
label="WholeStageCodegen (1)";
3622310 [labelType="html" label="MapPartitionsRDD [3622310]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298890 {
label="InMemoryTableScan";
3622311 [labelType="html" label="MapPartitionsRDD [3622311]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622312 [labelType="html" label="*(1) Project [CASE WHEN (date#94319357 = null) THEN null ELSE cast(date#94319357 as date) END AS date#94319470, CASE WHEN ((allret#94319358 = NA) OR (allret#94319358 = null)) THEN null ELSE cast(allret#94319358 as float) END AS allret#94319476, CASE WHEN ((allcum#94319359 = NA) OR (allcum#94319359 = null)) THEN null ELSE cast(allcum#94319359 as float) END AS allcum#94319477, CASE WHEN ((drawdown_gross#94319360 = NA) OR (drawdown_gross#94319360 = null)) THEN null ELSE cast(drawdown_gross#94319360 as float) END AS drawdown_gross#94319529, CASE WHEN ((drawdown_length_gross#94319361 = NA) OR (drawdown_length_gross#94319361 = null)) THEN null ELSE cast(drawdown_length_gross#94319361 as int) END AS drawdown_length_gross#94319579, CASE WHEN ((allretnet#94319362 = NA) OR (allretnet#94319362 = null)) THEN null ELSE cast(allretnet#94319362 as float) END AS allretnet#94319580, CASE WHEN ((allcumnet#94319363 = NA) OR (allcumnet#94319363 = null)) THEN null ELSE cast(allcumnet#94319363 as float) END AS allcumnet#9431958... [3622312] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299002 {
label="InMemoryTableScan";
3622375 [labelType="html" label="MapPartitionsRDD [3622375]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622376 [labelType="html" label="MapPartitionsRDD [3622376]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622377 [labelType="html" label="MapPartitionsRDD [3622377]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298999 {
label="WholeStageCodegen (1)";
3622378 [labelType="html" label="MapPartitionsRDD [3622378]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298998 {
label="Exchange";
3622382 [labelType="html" label="MapPartitionsRDD [3622382]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622308->3622309;
3622309->3622310;
3622310->3622311;
3622311->3622312;
3622312->3622375;
3622375->3622376;
3622376->3622377;
3622377->3622378;
3622378->3622382;
}