digraph G {
subgraph clusterstage_512940 {
label="Stage 512940";
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 cluster6301749 {
label="InMemoryTableScan";
3623957 [labelType="html" label="MapPartitionsRDD [3623957]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623958 [labelType="html" label="MapPartitionsRDD [3623958]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623959 [labelType="html" label="MapPartitionsRDD [3623959]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301746 {
label="WholeStageCodegen (1)";
3623960 [labelType="html" label="MapPartitionsRDD [3623960]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301745 {
label="Exchange";
3623964 [labelType="html" label="MapPartitionsRDD [3623964]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623931->3623932;
3623932->3623933;
3623933->3623934;
3623934->3623935;
3623935->3623957;
3623957->3623958;
3623958->3623959;
3623959->3623960;
3623960->3623964;
}