digraph G {
subgraph clusterstage_512352 {
label="Stage 512352";
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 cluster6294291 {
label="InMemoryTableScan";
3619664 [labelType="html" label="MapPartitionsRDD [3619664]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619665 [labelType="html" label="MapPartitionsRDD [3619665]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619666 [labelType="html" label="MapPartitionsRDD [3619666]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294290 {
label="Exchange";
3619670 [labelType="html" label="MapPartitionsRDD [3619670]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619617->3619618;
3619618->3619619;
3619619->3619620;
3619620->3619621;
3619621->3619664;
3619664->3619665;
3619665->3619666;
3619666->3619670;
}