digraph G {
subgraph clusterstage_512924 {
label="Stage 512924";
subgraph cluster6301539 {
label="Scan csv ";
3623817 [labelType="html" label="FileScanRDD [3623817]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623818 [labelType="html" label="MapPartitionsRDD [3623818]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301536 {
label="WholeStageCodegen (1)";
3623819 [labelType="html" label="MapPartitionsRDD [3623819]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301535 {
label="InMemoryTableScan";
3623820 [labelType="html" label="MapPartitionsRDD [3623820]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623821 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94360697 = NA) OR (fractile#94360697 = null)) THEN null ELSE cast(fractile#94360697 as int) END AS fractile#94360745, CASE WHEN (cap#94360698 = null) THEN null ELSE cap#94360698 END AS cap#94360746, CASE WHEN ((size#94360699 = NA) OR (size#94360699 = null)) THEN null ELSE cast(size#94360699 as float) END AS size#94360747, CASE WHEN ((value#94360700 = NA) OR (value#94360700 = null)) THEN null ELSE cast(value#94360700 as float) END AS value#94360748, CASE WHEN ((growth#94360701 = NA) OR (growth#94360701 = null)) THEN null ELSE cast(growth#94360701 as float) END AS growth#94360749, CASE WHEN ((leverage#94360702 = NA) OR (leverage#94360702 = null)) THEN null ELSE cast(leverage#94360702 as float) END AS leverage#94360750, CASE WHEN ((volatility#94360703 = NA) OR (volatility#94360703 = null)) THEN null ELSE cast(volatility#94360703 as float) END AS volatility#94360751, CASE WHEN ((momentum#94360704 = NA) OR (momentum#94360704 = null)) THEN null ELSE cast(momentum#94360704 as fl... [3623821] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623822 [labelType="html" label="MapPartitionsRDD [3623822]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623823 [labelType="html" label="MapPartitionsRDD [3623823]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623824 [labelType="html" label="MapPartitionsRDD [3623824]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301520 {
label="WholeStageCodegen (2)";
3623825 [labelType="html" label="MapPartitionsRDD [3623825]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301519 {
label="Exchange";
3623829 [labelType="html" label="MapPartitionsRDD [3623829]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623817->3623818;
3623818->3623819;
3623819->3623820;
3623820->3623821;
3623821->3623822;
3623822->3623823;
3623823->3623824;
3623824->3623825;
3623825->3623829;
}