digraph G {
subgraph clusterstage_512776 {
label="Stage 512776";
subgraph cluster6299667 {
label="Scan csv ";
3622737 [labelType="html" label="FileScanRDD [3622737]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622738 [labelType="html" label="MapPartitionsRDD [3622738]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299664 {
label="WholeStageCodegen (1)";
3622739 [labelType="html" label="MapPartitionsRDD [3622739]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299663 {
label="InMemoryTableScan";
3622740 [labelType="html" label="MapPartitionsRDD [3622740]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622741 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94332025 = NA) OR (fractile#94332025 = null)) THEN null ELSE cast(fractile#94332025 as int) END AS fractile#94332073, CASE WHEN (cap#94332026 = null) THEN null ELSE cap#94332026 END AS cap#94332074, CASE WHEN ((size#94332027 = NA) OR (size#94332027 = null)) THEN null ELSE cast(size#94332027 as float) END AS size#94332075, CASE WHEN ((value#94332028 = NA) OR (value#94332028 = null)) THEN null ELSE cast(value#94332028 as float) END AS value#94332076, CASE WHEN ((growth#94332029 = NA) OR (growth#94332029 = null)) THEN null ELSE cast(growth#94332029 as float) END AS growth#94332077, CASE WHEN ((leverage#94332030 = NA) OR (leverage#94332030 = null)) THEN null ELSE cast(leverage#94332030 as float) END AS leverage#94332078, CASE WHEN ((volatility#94332031 = NA) OR (volatility#94332031 = null)) THEN null ELSE cast(volatility#94332031 as float) END AS volatility#94332079, CASE WHEN ((momentum#94332032 = NA) OR (momentum#94332032 = null)) THEN null ELSE cast(momentum#94332032 as fl... [3622741] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622742 [labelType="html" label="MapPartitionsRDD [3622742]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622743 [labelType="html" label="MapPartitionsRDD [3622743]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3622744 [labelType="html" label="MapPartitionsRDD [3622744]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299648 {
label="WholeStageCodegen (2)";
3622745 [labelType="html" label="MapPartitionsRDD [3622745]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6299647 {
label="Exchange";
3622749 [labelType="html" label="MapPartitionsRDD [3622749]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3622737->3622738;
3622738->3622739;
3622739->3622740;
3622740->3622741;
3622741->3622742;
3622742->3622743;
3622743->3622744;
3622744->3622745;
3622745->3622749;
}