digraph G {
subgraph clusterstage_512421 {
label="Stage 512421";
subgraph cluster6295140 {
label="Scan csv ";
3620148 [labelType="html" label="FileScanRDD [3620148]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620149 [labelType="html" label="MapPartitionsRDD [3620149]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295137 {
label="WholeStageCodegen (1)";
3620150 [labelType="html" label="MapPartitionsRDD [3620150]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295136 {
label="InMemoryTableScan";
3620151 [labelType="html" label="MapPartitionsRDD [3620151]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620152 [labelType="html" label="*(1) Project [CASE WHEN (date#94262636 = null) THEN null ELSE cast(date#94262636 as date) END AS date#94262742, CASE WHEN ((allret#94262637 = NA) OR (allret#94262637 = null)) THEN null ELSE cast(allret#94262637 as float) END AS allret#94262748, CASE WHEN ((allcum#94262638 = NA) OR (allcum#94262638 = null)) THEN null ELSE cast(allcum#94262638 as float) END AS allcum#94262749, CASE WHEN ((drawdown_gross#94262639 = NA) OR (drawdown_gross#94262639 = null)) THEN null ELSE cast(drawdown_gross#94262639 as float) END AS drawdown_gross#94262750, CASE WHEN ((drawdown_length_gross#94262640 = NA) OR (drawdown_length_gross#94262640 = null)) THEN null ELSE cast(drawdown_length_gross#94262640 as int) END AS drawdown_length_gross#94262759, CASE WHEN ((allretnet#94262641 = NA) OR (allretnet#94262641 = null)) THEN null ELSE cast(allretnet#94262641 as float) END AS allretnet#94262760, CASE WHEN ((allcumnet#94262642 = NA) OR (allcumnet#94262642 = null)) THEN null ELSE cast(allcumnet#94262642 as float) END AS allcumnet#9426276... [3620152] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295180 {
label="InMemoryTableScan";
3620174 [labelType="html" label="MapPartitionsRDD [3620174]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620175 [labelType="html" label="MapPartitionsRDD [3620175]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620176 [labelType="html" label="MapPartitionsRDD [3620176]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295177 {
label="WholeStageCodegen (1)";
3620177 [labelType="html" label="MapPartitionsRDD [3620177]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6295176 {
label="Exchange";
3620178 [labelType="html" label="MapPartitionsRDD [3620178]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620179 [labelType="html" label="MapPartitionsRDD [3620179]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3620180 [labelType="html" label="MapPartitionsRDD [3620180]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3620148->3620149;
3620149->3620150;
3620150->3620151;
3620151->3620152;
3620152->3620174;
3620174->3620175;
3620175->3620176;
3620176->3620177;
3620177->3620178;
3620178->3620179;
3620179->3620180;
}