digraph G {
subgraph clusterstage_512652 {
label="Stage 512652";
subgraph cluster6297961 {
label="Scan csv ";
3621771 [labelType="html" label="FileScanRDD [3621771]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621772 [labelType="html" label="MapPartitionsRDD [3621772]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297958 {
label="WholeStageCodegen (1)";
3621773 [labelType="html" label="MapPartitionsRDD [3621773]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297957 {
label="InMemoryTableScan";
3621774 [labelType="html" label="MapPartitionsRDD [3621774]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621775 [labelType="html" label="*(1) Project [CASE WHEN (date#94305708 = null) THEN null ELSE cast(date#94305708 as date) END AS date#94305864, CASE WHEN ((allret#94305709 = NA) OR (allret#94305709 = null)) THEN null ELSE cast(allret#94305709 as float) END AS allret#94305867, CASE WHEN ((allcum#94305710 = NA) OR (allcum#94305710 = null)) THEN null ELSE cast(allcum#94305710 as float) END AS allcum#94305869, CASE WHEN ((drawdown_gross#94305711 = NA) OR (drawdown_gross#94305711 = null)) THEN null ELSE cast(drawdown_gross#94305711 as float) END AS drawdown_gross#94305870, CASE WHEN ((drawdown_length_gross#94305712 = NA) OR (drawdown_length_gross#94305712 = null)) THEN null ELSE cast(drawdown_length_gross#94305712 as int) END AS drawdown_length_gross#94305872, CASE WHEN ((allretnet#94305713 = NA) OR (allretnet#94305713 = null)) THEN null ELSE cast(allretnet#94305713 as float) END AS allretnet#94305875, CASE WHEN ((allcumnet#94305714 = NA) OR (allcumnet#94305714 = null)) THEN null ELSE cast(allcumnet#94305714 as float) END AS allcumnet#9430587... [3621775] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298069 {
label="InMemoryTableScan";
3621838 [labelType="html" label="MapPartitionsRDD [3621838]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621839 [labelType="html" label="MapPartitionsRDD [3621839]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621840 [labelType="html" label="MapPartitionsRDD [3621840]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298066 {
label="WholeStageCodegen (1)";
3621841 [labelType="html" label="MapPartitionsRDD [3621841]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298065 {
label="Exchange";
3621845 [labelType="html" label="MapPartitionsRDD [3621845]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621771->3621772;
3621772->3621773;
3621773->3621774;
3621774->3621775;
3621775->3621838;
3621838->3621839;
3621839->3621840;
3621840->3621841;
3621841->3621845;
}