digraph G {
subgraph clusterstage_512998 {
label="Stage 512998";
subgraph cluster6302482 {
label="Scan csv ";
3624360 [labelType="html" label="FileScanRDD [3624360]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624361 [labelType="html" label="MapPartitionsRDD [3624361]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302479 {
label="WholeStageCodegen (1)";
3624362 [labelType="html" label="MapPartitionsRDD [3624362]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302478 {
label="InMemoryTableScan";
3624363 [labelType="html" label="MapPartitionsRDD [3624363]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624364 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94375154 = NA) OR (fractile#94375154 = null)) THEN null ELSE cast(fractile#94375154 as int) END AS fractile#94375202, CASE WHEN (cap#94375155 = null) THEN null ELSE cap#94375155 END AS cap#94375203, CASE WHEN ((size#94375156 = NA) OR (size#94375156 = null)) THEN null ELSE cast(size#94375156 as float) END AS size#94375204, CASE WHEN ((value#94375157 = NA) OR (value#94375157 = null)) THEN null ELSE cast(value#94375157 as float) END AS value#94375205, CASE WHEN ((growth#94375158 = NA) OR (growth#94375158 = null)) THEN null ELSE cast(growth#94375158 as float) END AS growth#94375206, CASE WHEN ((leverage#94375159 = NA) OR (leverage#94375159 = null)) THEN null ELSE cast(leverage#94375159 as float) END AS leverage#94375207, CASE WHEN ((volatility#94375160 = NA) OR (volatility#94375160 = null)) THEN null ELSE cast(volatility#94375160 as float) END AS volatility#94375208, CASE WHEN ((momentum#94375161 = NA) OR (momentum#94375161 = null)) THEN null ELSE cast(momentum#94375161 as fl... [3624364] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624365 [labelType="html" label="MapPartitionsRDD [3624365]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624366 [labelType="html" label="MapPartitionsRDD [3624366]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624367 [labelType="html" label="MapPartitionsRDD [3624367]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302463 {
label="WholeStageCodegen (2)";
3624368 [labelType="html" label="MapPartitionsRDD [3624368]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302462 {
label="Exchange";
3624372 [labelType="html" label="MapPartitionsRDD [3624372]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624360->3624361;
3624361->3624362;
3624362->3624363;
3624363->3624364;
3624364->3624365;
3624365->3624366;
3624366->3624367;
3624367->3624368;
3624368->3624372;
}