digraph G {
subgraph clusterstage_512648 {
label="Stage 512648";
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 cluster6298034 {
label="InMemoryTableScan";
3621818 [labelType="html" label="MapPartitionsRDD [3621818]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621819 [labelType="html" label="MapPartitionsRDD [3621819]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621820 [labelType="html" label="MapPartitionsRDD [3621820]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6298033 {
label="Exchange";
3621824 [labelType="html" label="MapPartitionsRDD [3621824]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621771->3621772;
3621772->3621773;
3621773->3621774;
3621774->3621775;
3621775->3621818;
3621818->3621819;
3621819->3621820;
3621820->3621824;
}