digraph G {
subgraph clusterstage_512348 {
label="Stage 512348";
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 cluster6294258 {
label="InMemoryTableScan";
3619643 [labelType="html" label="MapPartitionsRDD [3619643]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619644 [labelType="html" label="MapPartitionsRDD [3619644]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619645 [labelType="html" label="MapPartitionsRDD [3619645]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294255 {
label="WholeStageCodegen (1)";
3619646 [labelType="html" label="MapPartitionsRDD [3619646]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294254 {
label="Exchange";
3619650 [labelType="html" label="MapPartitionsRDD [3619650]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619617->3619618;
3619618->3619619;
3619619->3619620;
3619620->3619621;
3619621->3619643;
3619643->3619644;
3619644->3619645;
3619645->3619646;
3619646->3619650;
}