digraph G {
subgraph clusterstage_511756 {
label="Stage 511756";
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 cluster6286917 {
label="InMemoryTableScan";
3615429 [labelType="html" label="MapPartitionsRDD [3615429]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615430 [labelType="html" label="MapPartitionsRDD [3615430]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615431 [labelType="html" label="MapPartitionsRDD [3615431]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286845 {
label="WholeStageCodegen (2)";
3615432 [labelType="html" label="MapPartitionsRDD [3615432]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286844 {
label="Exchange";
3615433 [labelType="html" label="MapPartitionsRDD [3615433]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615434 [labelType="html" label="MapPartitionsRDD [3615434]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615435 [labelType="html" label="MapPartitionsRDD [3615435]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3610726->3610727;
3610727->3610728;
3610728->3610729;
3610729->3610730;
3610730->3615429;
3615429->3615430;
3615430->3615431;
3615431->3615432;
3615432->3615433;
3615433->3615434;
3615434->3615435;
}