digraph G {
subgraph clusterstage_512644 {
label="Stage 512644";
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 cluster6298001 {
label="InMemoryTableScan";
3621797 [labelType="html" label="MapPartitionsRDD [3621797]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621798 [labelType="html" label="MapPartitionsRDD [3621798]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3621799 [labelType="html" label="MapPartitionsRDD [3621799]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297998 {
label="WholeStageCodegen (1)";
3621800 [labelType="html" label="MapPartitionsRDD [3621800]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6297997 {
label="Exchange";
3621804 [labelType="html" label="MapPartitionsRDD [3621804]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3621771->3621772;
3621772->3621773;
3621773->3621774;
3621774->3621775;
3621775->3621797;
3621797->3621798;
3621798->3621799;
3621799->3621800;
3621800->3621804;
}