digraph G {
subgraph clusterstage_513001 {
label="Stage 513001";
subgraph cluster6302527 {
label="Scan csv ";
3624386 [labelType="html" label="FileScanRDD [3624386]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624387 [labelType="html" label="MapPartitionsRDD [3624387]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302524 {
label="WholeStageCodegen (1)";
3624388 [labelType="html" label="MapPartitionsRDD [3624388]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302523 {
label="InMemoryTableScan";
3624389 [labelType="html" label="MapPartitionsRDD [3624389]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624390 [labelType="html" label="*(1) Project [CASE WHEN ((overall#94371389 = NA) OR (overall#94371389 = null)) THEN null ELSE cast(overall#94371389 as int) END AS overall#94371629, CASE WHEN ((cap#94371390 = NA) OR (cap#94371390 = null)) THEN null ELSE cast(cap#94371390 as float) END AS cap#94371631, CASE WHEN ((retIC#94371391 = NA) OR (retIC#94371391 = null)) THEN null ELSE cast(retIC#94371391 as float) END AS retIC#94371633, CASE WHEN ((resretIC#94371392 = NA) OR (resretIC#94371392 = null)) THEN null ELSE cast(resretIC#94371392 as float) END AS resretIC#94371635, CASE WHEN ((size#94371393 = NA) OR (size#94371393 = null)) THEN null ELSE cast(size#94371393 as float) END AS size#94371637, CASE WHEN ((value#94371394 = NA) OR (value#94371394 = null)) THEN null ELSE cast(value#94371394 as float) END AS value#94371639, CASE WHEN ((growth#94371395 = NA) OR (growth#94371395 = null)) THEN null ELSE cast(growth#94371395 as float) END AS growth#94371641, CASE WHEN ((leverage#94371396 = NA) OR (leverage#94371396 = null)) THEN null ELSE cast(leverag... [3624390] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624391 [labelType="html" label="MapPartitionsRDD [3624391]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624392 [labelType="html" label="MapPartitionsRDD [3624392]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624393 [labelType="html" label="MapPartitionsRDD [3624393]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302518 {
label="WholeStageCodegen (1)";
3624394 [labelType="html" label="MapPartitionsRDD [3624394]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302517 {
label="InMemoryTableScan";
3624395 [labelType="html" label="MapPartitionsRDD [3624395]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624396 [labelType="html" label="*(1) Project [yield#94371649, volatility#94371645, momentum#94371647, size#94371637, value#94371639, growth#94371641, leverage#94371643]\n+- *(1) Filter (isnotnull(cap#94371631) AND (cap#94371631 = 0.0))\n +- *(1) ColumnarToRow\n +- InMemoryTableScan [cap#94371631, growth#94371641, leverage#94371643, momentum#94371647, size#94371637, value#94371639, volatility#94371645, yield#94371649], [isnotnull(cap#94371631), (cap#94371631 = 0.0)]\n +- InMemoryRelation [overall#94371629, cap#94371631, retIC#94371633, resretIC#94371635, size#94371637, value#94371639, growth#94371641, leverage#94371643, volatility#94371645, momentum#94371647, yield#94371649, numcos#94371651, numdates#94371653, annual_bmret#94371655, annual_ret#94371657, std_ret#94371659, Sharpe_ret#94371661, PctPos_ret#94371663, TR_ret#94371664, IR_ret#94371665, annual_resret#94371666, std_resret#94371667, Sharpe_resret#94371668, PctPos_resret#94371669, ... 9 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)\n ... [3624396] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624397 [labelType="html" label="MapPartitionsRDD [3624397]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624398 [labelType="html" label="MapPartitionsRDD [3624398]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3624399 [labelType="html" label="MapPartitionsRDD [3624399]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302514 {
label="WholeStageCodegen (1)";
3624400 [labelType="html" label="MapPartitionsRDD [3624400]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302513 {
label="CollectLimit";
3624401 [labelType="html" label="MapPartitionsRDD [3624401]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302528 {
label="mapPartitionsInternal";
3624402 [labelType="html" label="MapPartitionsRDD [3624402]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6302529 {
label="map";
3624403 [labelType="html" label="MapPartitionsRDD [3624403]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3624386->3624387;
3624387->3624388;
3624388->3624389;
3624389->3624390;
3624390->3624391;
3624391->3624392;
3624392->3624393;
3624393->3624394;
3624394->3624395;
3624395->3624396;
3624396->3624397;
3624397->3624398;
3624398->3624399;
3624399->3624400;
3624400->3624401;
3624401->3624402;
3624402->3624403;
}
3624390
3624396