digraph G {
subgraph clusterstage_511715 {
label="Stage 511715";
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 cluster6286545 {
label="InMemoryTableScan";
3615231 [labelType="html" label="MapPartitionsRDD [3615231]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615232 [labelType="html" label="MapPartitionsRDD [3615232]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615233 [labelType="html" label="MapPartitionsRDD [3615233]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286456 {
label="WholeStageCodegen (2)";
3615234 [labelType="html" label="MapPartitionsRDD [3615234]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286455 {
label="Exchange";
3615235 [labelType="html" label="MapPartitionsRDD [3615235]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615236 [labelType="html" label="MapPartitionsRDD [3615236]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615237 [labelType="html" label="MapPartitionsRDD [3615237]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610726->3610727;
3610727->3610728;
3610728->3610729;
3610729->3610730;
3610730->3615231;
3615231->3615232;
3615232->3615233;
3615233->3615234;
3615234->3615235;
3615235->3615236;
3615236->3615237;
}