digraph G {
subgraph clusterstage_513091 {
label="Stage 513091";
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"];
}
subgraph cluster6303659 {
label="InMemoryTableScan";
3625058 [labelType="html" label="MapPartitionsRDD [3625058]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625059 [labelType="html" label="MapPartitionsRDD [3625059]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625060 [labelType="html" label="MapPartitionsRDD [3625060]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303658 {
label="Exchange";
3625061 [labelType="html" label="MapPartitionsRDD [3625061]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625062 [labelType="html" label="MapPartitionsRDD [3625062]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625063 [labelType="html" label="MapPartitionsRDD [3625063]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625011->3625012;
3625012->3625013;
3625013->3625014;
3625014->3625015;
3625015->3625058;
3625058->3625059;
3625059->3625060;
3625060->3625061;
3625061->3625062;
3625062->3625063;
}