digraph G {
subgraph clusterstage_513083 {
label="Stage 513083";
subgraph cluster6303586 {
label="Scan csv ";
3625011 [labelType="html" label="FileScanRDD [3625011]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625012 [labelType="html" label="MapPartitionsRDD [3625012]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303583 {
label="WholeStageCodegen (1)";
3625013 [labelType="html" label="MapPartitionsRDD [3625013]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303582 {
label="InMemoryTableScan";
3625014 [labelType="html" label="MapPartitionsRDD [3625014]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625015 [labelType="html" label="*(1) Project [CASE WHEN (date#94390885 = null) THEN null ELSE cast(date#94390885 as date) END AS date#94390995, CASE WHEN ((allret#94390886 = NA) OR (allret#94390886 = null)) THEN null ELSE cast(allret#94390886 as float) END AS allret#94390996, CASE WHEN ((allcum#94390887 = NA) OR (allcum#94390887 = null)) THEN null ELSE cast(allcum#94390887 as float) END AS allcum#94390997, CASE WHEN ((drawdown_gross#94390888 = NA) OR (drawdown_gross#94390888 = null)) THEN null ELSE cast(drawdown_gross#94390888 as float) END AS drawdown_gross#94391008, CASE WHEN ((drawdown_length_gross#94390889 = NA) OR (drawdown_length_gross#94390889 = null)) THEN null ELSE cast(drawdown_length_gross#94390889 as int) END AS drawdown_length_gross#94391010, CASE WHEN ((allretnet#94390890 = NA) OR (allretnet#94390890 = null)) THEN null ELSE cast(allretnet#94390890 as float) END AS allretnet#94391011, CASE WHEN ((allcumnet#94390891 = NA) OR (allcumnet#94390891 = null)) THEN null ELSE cast(allcumnet#94390891 as float) END AS allcumnet#9439110... [3625015] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625016 [labelType="html" label="MapPartitionsRDD [3625016]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625017 [labelType="html" label="MapPartitionsRDD [3625017]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625018 [labelType="html" label="MapPartitionsRDD [3625018]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303579 {
label="WholeStageCodegen (1)";
3625019 [labelType="html" label="MapPartitionsRDD [3625019]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303578 {
label="Exchange";
3625020 [labelType="html" label="MapPartitionsRDD [3625020]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625021 [labelType="html" label="MapPartitionsRDD [3625021]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625022 [labelType="html" label="MapPartitionsRDD [3625022]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625011->3625012;
3625012->3625013;
3625013->3625014;
3625014->3625015;
3625015->3625016;
3625016->3625017;
3625017->3625018;
3625018->3625019;
3625019->3625020;
3625020->3625021;
3625021->3625022;
}