digraph G {
subgraph clusterstage_512936 {
label="Stage 512936";
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"];
3623936 [labelType="html" label="MapPartitionsRDD [3623936]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623937 [labelType="html" label="MapPartitionsRDD [3623937]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623938 [labelType="html" label="MapPartitionsRDD [3623938]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301702 {
label="WholeStageCodegen (1)";
3623939 [labelType="html" label="MapPartitionsRDD [3623939]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301701 {
label="Exchange";
3623943 [labelType="html" label="MapPartitionsRDD [3623943]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623931->3623932;
3623932->3623933;
3623933->3623934;
3623934->3623935;
3623935->3623936;
3623936->3623937;
3623937->3623938;
3623938->3623939;
3623939->3623943;
}