digraph G {
subgraph clusterstage_512944 {
label="Stage 512944";
subgraph cluster6301709 {
label="Scan csv ";
3623931 [labelType="html" label="FileScanRDD [3623931]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623932 [labelType="html" label="MapPartitionsRDD [3623932]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301706 {
label="WholeStageCodegen (1)";
3623933 [labelType="html" label="MapPartitionsRDD [3623933]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301705 {
label="InMemoryTableScan";
3623934 [labelType="html" label="MapPartitionsRDD [3623934]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623935 [labelType="html" label="*(1) Project [CASE WHEN (date#94362604 = null) THEN null ELSE cast(date#94362604 as date) END AS date#94362737, CASE WHEN ((allret#94362605 = NA) OR (allret#94362605 = null)) THEN null ELSE cast(allret#94362605 as float) END AS allret#94362743, CASE WHEN ((allcum#94362606 = NA) OR (allcum#94362606 = null)) THEN null ELSE cast(allcum#94362606 as float) END AS allcum#94362749, CASE WHEN ((drawdown_gross#94362607 = NA) OR (drawdown_gross#94362607 = null)) THEN null ELSE cast(drawdown_gross#94362607 as float) END AS drawdown_gross#94362750, CASE WHEN ((drawdown_length_gross#94362608 = NA) OR (drawdown_length_gross#94362608 = null)) THEN null ELSE cast(drawdown_length_gross#94362608 as int) END AS drawdown_length_gross#94362751, CASE WHEN ((allretnet#94362609 = NA) OR (allretnet#94362609 = null)) THEN null ELSE cast(allretnet#94362609 as float) END AS allretnet#94362757, CASE WHEN ((allcumnet#94362610 = NA) OR (allcumnet#94362610 = null)) THEN null ELSE cast(allcumnet#94362610 as float) END AS allcumnet#9436278... [3623935] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301782 {
label="InMemoryTableScan";
3623978 [labelType="html" label="MapPartitionsRDD [3623978]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623979 [labelType="html" label="MapPartitionsRDD [3623979]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623980 [labelType="html" label="MapPartitionsRDD [3623980]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301781 {
label="Exchange";
3623984 [labelType="html" label="MapPartitionsRDD [3623984]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623931->3623932;
3623932->3623933;
3623933->3623934;
3623934->3623935;
3623935->3623978;
3623978->3623979;
3623979->3623980;
3623980->3623984;
}