digraph G {
subgraph clusterstage_512356 {
label="Stage 512356";
subgraph cluster6294218 {
label="Scan csv ";
3619617 [labelType="html" label="FileScanRDD [3619617]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619618 [labelType="html" label="MapPartitionsRDD [3619618]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294215 {
label="WholeStageCodegen (1)";
3619619 [labelType="html" label="MapPartitionsRDD [3619619]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294214 {
label="InMemoryTableScan";
3619620 [labelType="html" label="MapPartitionsRDD [3619620]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619621 [labelType="html" label="*(1) Project [CASE WHEN (date#94250069 = null) THEN null ELSE cast(date#94250069 as date) END AS date#94250291, CASE WHEN ((allret#94250070 = NA) OR (allret#94250070 = null)) THEN null ELSE cast(allret#94250070 as float) END AS allret#94250292, CASE WHEN ((allcum#94250071 = NA) OR (allcum#94250071 = null)) THEN null ELSE cast(allcum#94250071 as float) END AS allcum#94250293, CASE WHEN ((drawdown_gross#94250072 = NA) OR (drawdown_gross#94250072 = null)) THEN null ELSE cast(drawdown_gross#94250072 as float) END AS drawdown_gross#94250294, CASE WHEN ((drawdown_length_gross#94250073 = NA) OR (drawdown_length_gross#94250073 = null)) THEN null ELSE cast(drawdown_length_gross#94250073 as int) END AS drawdown_length_gross#94250295, CASE WHEN ((allretnet#94250074 = NA) OR (allretnet#94250074 = null)) THEN null ELSE cast(allretnet#94250074 as float) END AS allretnet#94250296, CASE WHEN ((allcumnet#94250075 = NA) OR (allcumnet#94250075 = null)) THEN null ELSE cast(allcumnet#94250075 as float) END AS allcumnet#9425029... [3619621] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294326 {
label="InMemoryTableScan";
3619684 [labelType="html" label="MapPartitionsRDD [3619684]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619685 [labelType="html" label="MapPartitionsRDD [3619685]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619686 [labelType="html" label="MapPartitionsRDD [3619686]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294323 {
label="WholeStageCodegen (1)";
3619687 [labelType="html" label="MapPartitionsRDD [3619687]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294322 {
label="Exchange";
3619691 [labelType="html" label="MapPartitionsRDD [3619691]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619617->3619618;
3619618->3619619;
3619619->3619620;
3619620->3619621;
3619621->3619684;
3619684->3619685;
3619685->3619686;
3619686->3619687;
3619687->3619691;
}