digraph G {
subgraph clusterstage_512344 {
label="Stage 512344";
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"];
3619622 [labelType="html" label="MapPartitionsRDD [3619622]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619623 [labelType="html" label="MapPartitionsRDD [3619623]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3619624 [labelType="html" label="MapPartitionsRDD [3619624]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294211 {
label="WholeStageCodegen (1)";
3619625 [labelType="html" label="MapPartitionsRDD [3619625]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6294210 {
label="Exchange";
3619629 [labelType="html" label="MapPartitionsRDD [3619629]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3619617->3619618;
3619618->3619619;
3619619->3619620;
3619620->3619621;
3619621->3619622;
3619622->3619623;
3619623->3619624;
3619624->3619625;
3619625->3619629;
}