digraph G {
subgraph clusterstage_511790 {
label="Stage 511790";
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 cluster6287162 {
label="InMemoryTableScan";
3615564 [labelType="html" label="MapPartitionsRDD [3615564]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615565 [labelType="html" label="MapPartitionsRDD [3615565]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615566 [labelType="html" label="MapPartitionsRDD [3615566]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287159 {
label="WholeStageCodegen (1)";
3615575 [labelType="html" label="MapPartitionsRDD [3615575]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287158 {
label="Exchange";
3615582 [labelType="html" label="MapPartitionsRDD [3615582]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615583 [labelType="html" label="MapPartitionsRDD [3615583]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615586 [labelType="html" label="MapPartitionsRDD [3615586]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610297->3610298;
3610298->3610299;
3610299->3610300;
3610300->3610301;
3610301->3615564;
3615564->3615565;
3615565->3615566;
3615566->3615575;
3615575->3615582;
3615582->3615583;
3615583->3615586;
}