digraph G {
subgraph clusterstage_511718 {
label="Stage 511718";
subgraph cluster6277967 {
label="Scan csv ";
3610297 [labelType="html" label="FileScanRDD [3610297]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610298 [labelType="html" label="MapPartitionsRDD [3610298]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6277964 {
label="WholeStageCodegen (1)";
3610299 [labelType="html" label="MapPartitionsRDD [3610299]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6277963 {
label="InMemoryTableScan";
3610300 [labelType="html" label="MapPartitionsRDD [3610300]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610301 [labelType="html" label="*(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END AS allret#94005336, CASE WHEN ((allcum#94005176 = NA) OR (allcum#94005176 = null)) THEN null ELSE cast(allcum#94005176 as float) END AS allcum#94005360, CASE WHEN ((drawdown_gross#94005177 = NA) OR (drawdown_gross#94005177 = null)) THEN null ELSE cast(drawdown_gross#94005177 as float) END AS drawdown_gross#94005361, CASE WHEN ((drawdown_length_gross#94005178 = NA) OR (drawdown_length_gross#94005178 = null)) THEN null ELSE cast(drawdown_length_gross#94005178 as int) END AS drawdown_length_gross#94005385, CASE WHEN ((allretnet#94005179 = NA) OR (allretnet#94005179 = null)) THEN null ELSE cast(allretnet#94005179 as float) END AS allretnet#94005389, CASE WHEN ((allcumnet#94005180 = NA) OR (allcumnet#94005180 = null)) THEN null ELSE cast(allcumnet#94005180 as float) END AS allcumnet#9400539... [3610301] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286584 {
label="InMemoryTableScan";
3615253 [labelType="html" label="MapPartitionsRDD [3615253]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615255 [labelType="html" label="MapPartitionsRDD [3615255]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615258 [labelType="html" label="MapPartitionsRDD [3615258]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286581 {
label="WholeStageCodegen (1)";
3615264 [labelType="html" label="MapPartitionsRDD [3615264]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286580 {
label="Exchange";
3615266 [labelType="html" label="MapPartitionsRDD [3615266]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615268 [labelType="html" label="MapPartitionsRDD [3615268]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615269 [labelType="html" label="MapPartitionsRDD [3615269]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610297->3610298;
3610298->3610299;
3610299->3610300;
3610300->3610301;
3610301->3615253;
3615253->3615255;
3615255->3615258;
3615258->3615264;
3615264->3615266;
3615266->3615268;
3615268->3615269;
}