digraph G {
subgraph clusterstage_513145 {
label="Stage 513145";
subgraph cluster6304348 {
label="Scan csv ";
3625434 [labelType="html" label="FileScanRDD [3625434]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625435 [labelType="html" label="MapPartitionsRDD [3625435]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304345 {
label="WholeStageCodegen (1)";
3625436 [labelType="html" label="MapPartitionsRDD [3625436]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304344 {
label="InMemoryTableScan";
3625437 [labelType="html" label="MapPartitionsRDD [3625437]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625438 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94402944 = NA) OR (fractile#94402944 = null)) THEN null ELSE cast(fractile#94402944 as int) END AS fractile#94402992, CASE WHEN (cap#94402945 = null) THEN null ELSE cap#94402945 END AS cap#94402993, CASE WHEN ((size#94402946 = NA) OR (size#94402946 = null)) THEN null ELSE cast(size#94402946 as float) END AS size#94402994, CASE WHEN ((value#94402947 = NA) OR (value#94402947 = null)) THEN null ELSE cast(value#94402947 as float) END AS value#94402995, CASE WHEN ((growth#94402948 = NA) OR (growth#94402948 = null)) THEN null ELSE cast(growth#94402948 as float) END AS growth#94402996, CASE WHEN ((leverage#94402949 = NA) OR (leverage#94402949 = null)) THEN null ELSE cast(leverage#94402949 as float) END AS leverage#94402997, CASE WHEN ((volatility#94402950 = NA) OR (volatility#94402950 = null)) THEN null ELSE cast(volatility#94402950 as float) END AS volatility#94402998, CASE WHEN ((momentum#94402951 = NA) OR (momentum#94402951 = null)) THEN null ELSE cast(momentum#94402951 as fl... [3625438] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625439 [labelType="html" label="MapPartitionsRDD [3625439]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625440 [labelType="html" label="MapPartitionsRDD [3625440]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625441 [labelType="html" label="MapPartitionsRDD [3625441]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304329 {
label="WholeStageCodegen (2)";
3625442 [labelType="html" label="MapPartitionsRDD [3625442]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6304328 {
label="Exchange";
3625443 [labelType="html" label="MapPartitionsRDD [3625443]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625444 [labelType="html" label="MapPartitionsRDD [3625444]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3625445 [labelType="html" label="MapPartitionsRDD [3625445]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3625434->3625435;
3625435->3625436;
3625436->3625437;
3625437->3625438;
3625438->3625439;
3625439->3625440;
3625440->3625441;
3625441->3625442;
3625442->3625443;
3625443->3625444;
3625444->3625445;
}