digraph G {
subgraph clusterstage_512850 {
label="Stage 512850";
subgraph cluster6300611 {
label="Scan csv ";
3623280 [labelType="html" label="FileScanRDD [3623280]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623281 [labelType="html" label="MapPartitionsRDD [3623281]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300608 {
label="WholeStageCodegen (1)";
3623282 [labelType="html" label="MapPartitionsRDD [3623282]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300607 {
label="InMemoryTableScan";
3623283 [labelType="html" label="MapPartitionsRDD [3623283]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623284 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94346372 = NA) OR (fractile#94346372 = null)) THEN null ELSE cast(fractile#94346372 as int) END AS fractile#94346420, CASE WHEN (cap#94346373 = null) THEN null ELSE cap#94346373 END AS cap#94346421, CASE WHEN ((size#94346374 = NA) OR (size#94346374 = null)) THEN null ELSE cast(size#94346374 as float) END AS size#94346422, CASE WHEN ((value#94346375 = NA) OR (value#94346375 = null)) THEN null ELSE cast(value#94346375 as float) END AS value#94346423, CASE WHEN ((growth#94346376 = NA) OR (growth#94346376 = null)) THEN null ELSE cast(growth#94346376 as float) END AS growth#94346424, CASE WHEN ((leverage#94346377 = NA) OR (leverage#94346377 = null)) THEN null ELSE cast(leverage#94346377 as float) END AS leverage#94346425, CASE WHEN ((volatility#94346378 = NA) OR (volatility#94346378 = null)) THEN null ELSE cast(volatility#94346378 as float) END AS volatility#94346426, CASE WHEN ((momentum#94346379 = NA) OR (momentum#94346379 = null)) THEN null ELSE cast(momentum#94346379 as fl... [3623284] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623285 [labelType="html" label="MapPartitionsRDD [3623285]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623286 [labelType="html" label="MapPartitionsRDD [3623286]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623287 [labelType="html" label="MapPartitionsRDD [3623287]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300592 {
label="WholeStageCodegen (2)";
3623288 [labelType="html" label="MapPartitionsRDD [3623288]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300591 {
label="Exchange";
3623292 [labelType="html" label="MapPartitionsRDD [3623292]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3623280->3623281;
3623281->3623282;
3623282->3623283;
3623283->3623284;
3623284->3623285;
3623285->3623286;
3623286->3623287;
3623287->3623288;
3623288->3623292;
}