digraph G {
subgraph clusterstage_511810 {
label="Stage 511810";
subgraph cluster6278734 {
label="Scan csv ";
3610726 [labelType="html" label="FileScanRDD [3610726]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610727 [labelType="html" label="MapPartitionsRDD [3610727]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278731 {
label="WholeStageCodegen (1)";
3610728 [labelType="html" label="MapPartitionsRDD [3610728]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278730 {
label="InMemoryTableScan";
3610729 [labelType="html" label="MapPartitionsRDD [3610729]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610730 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94017781 = NA) OR (fractile#94017781 = null)) THEN null ELSE cast(fractile#94017781 as int) END AS fractile#94017829, CASE WHEN (cap#94017782 = null) THEN null ELSE cap#94017782 END AS cap#94017830, CASE WHEN ((size#94017783 = NA) OR (size#94017783 = null)) THEN null ELSE cast(size#94017783 as float) END AS size#94017831, CASE WHEN ((value#94017784 = NA) OR (value#94017784 = null)) THEN null ELSE cast(value#94017784 as float) END AS value#94017832, CASE WHEN ((growth#94017785 = NA) OR (growth#94017785 = null)) THEN null ELSE cast(growth#94017785 as float) END AS growth#94017833, CASE WHEN ((leverage#94017786 = NA) OR (leverage#94017786 = null)) THEN null ELSE cast(leverage#94017786 as float) END AS leverage#94017834, CASE WHEN ((volatility#94017787 = NA) OR (volatility#94017787 = null)) THEN null ELSE cast(volatility#94017787 as float) END AS volatility#94017835, CASE WHEN ((momentum#94017788 = NA) OR (momentum#94017788 = null)) THEN null ELSE cast(momentum#94017788 as fl... [3610730] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287436 {
label="InMemoryTableScan";
3615688 [labelType="html" label="MapPartitionsRDD [3615688]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615689 [labelType="html" label="MapPartitionsRDD [3615689]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615690 [labelType="html" label="MapPartitionsRDD [3615690]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287338 {
label="WholeStageCodegen (2)";
3615691 [labelType="html" label="MapPartitionsRDD [3615691]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287337 {
label="Exchange";
3615692 [labelType="html" label="MapPartitionsRDD [3615692]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615693 [labelType="html" label="MapPartitionsRDD [3615693]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615694 [labelType="html" label="MapPartitionsRDD [3615694]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610726->3610727;
3610727->3610728;
3610728->3610729;
3610729->3610730;
3610730->3615688;
3615688->3615689;
3615689->3615690;
3615690->3615691;
3615691->3615692;
3615692->3615693;
3615693->3615694;
}