digraph G {
subgraph clusterstage_513071 {
label="Stage 513071";
subgraph cluster6303415 {
label="Scan csv ";
3624897 [labelType="html" label="FileScanRDD [3624897]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624898 [labelType="html" label="MapPartitionsRDD [3624898]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303412 {
label="WholeStageCodegen (1)";
3624899 [labelType="html" label="MapPartitionsRDD [3624899]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303411 {
label="InMemoryTableScan";
3624900 [labelType="html" label="MapPartitionsRDD [3624900]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624901 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94389049 = NA) OR (fractile#94389049 = null)) THEN null ELSE cast(fractile#94389049 as int) END AS fractile#94389097, CASE WHEN (cap#94389050 = null) THEN null ELSE cap#94389050 END AS cap#94389098, CASE WHEN ((size#94389051 = NA) OR (size#94389051 = null)) THEN null ELSE cast(size#94389051 as float) END AS size#94389099, CASE WHEN ((value#94389052 = NA) OR (value#94389052 = null)) THEN null ELSE cast(value#94389052 as float) END AS value#94389100, CASE WHEN ((growth#94389053 = NA) OR (growth#94389053 = null)) THEN null ELSE cast(growth#94389053 as float) END AS growth#94389101, CASE WHEN ((leverage#94389054 = NA) OR (leverage#94389054 = null)) THEN null ELSE cast(leverage#94389054 as float) END AS leverage#94389102, CASE WHEN ((volatility#94389055 = NA) OR (volatility#94389055 = null)) THEN null ELSE cast(volatility#94389055 as float) END AS volatility#94389103, CASE WHEN ((momentum#94389056 = NA) OR (momentum#94389056 = null)) THEN null ELSE cast(momentum#94389056 as fl... [3624901] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624902 [labelType="html" label="MapPartitionsRDD [3624902]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624903 [labelType="html" label="MapPartitionsRDD [3624903]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624904 [labelType="html" label="MapPartitionsRDD [3624904]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303396 {
label="WholeStageCodegen (2)";
3624905 [labelType="html" label="MapPartitionsRDD [3624905]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6303395 {
label="Exchange";
3624906 [labelType="html" label="MapPartitionsRDD [3624906]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624907 [labelType="html" label="MapPartitionsRDD [3624907]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624908 [labelType="html" label="MapPartitionsRDD [3624908]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624897->3624898;
3624898->3624899;
3624899->3624900;
3624900->3624901;
3624901->3624902;
3624902->3624903;
3624903->3624904;
3624904->3624905;
3624905->3624906;
3624906->3624907;
3624907->3624908;
}