digraph G {
subgraph clusterstage_511735 {
label="Stage 511735";
subgraph cluster6269650 {
label="Scan csv ";
3605506 [labelType="html" label="FileScanRDD [3605506]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3605507 [labelType="html" label="MapPartitionsRDD [3605507]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6269647 {
label="WholeStageCodegen (1)";
3605508 [labelType="html" label="MapPartitionsRDD [3605508]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6269646 {
label="InMemoryTableScan";
3605509 [labelType="html" label="MapPartitionsRDD [3605509]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3605510 [labelType="html" label="*(1) Project [CASE WHEN (group#93875754 = null) THEN null ELSE group#93875754 END AS group#93875766, CASE WHEN (Category#93875755 = null) THEN null ELSE Category#93875755 END AS Category#93875767, CASE WHEN (Label#93875756 = null) THEN null ELSE Label#93875756 END AS Label#93875768]\n+- FileScan csv [group#93875754,Category#93875755,Label#93875756] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/common/map_stats.csv], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<group:string,Category:string,Label:string>\n [3605510] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6278187 {
label="InMemoryTableScan";
3610426 [labelType="html" label="MapPartitionsRDD [3610426]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610427 [labelType="html" label="MapPartitionsRDD [3610427]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610428 [labelType="html" label="MapPartitionsRDD [3610428]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278162 {
label="WholeStageCodegen (2)";
3610429 [labelType="html" label="MapPartitionsRDD [3610429]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6278161 {
label="InMemoryTableScan";
3610430 [labelType="html" label="MapPartitionsRDD [3610430]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3610431 [labelType="html" label="*(2) Project [Category#93875767, Label#93875768, annual_ret#94006310, Sharpe_ret#94006312, PctPos_ret#94006313, annual_resret#94006316, Sharpe_resret#94006318, PctPos_resret#94006319, annual_retnet#94006322, Sharpe_retnet#94006324, PctPos_retnet#94006325]\n+- *(2) BroadcastHashJoin [group#94006308], [group#93875766], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [id=#7505834]\n : +- *(1) Filter isnotnull(group#94006308)\n : +- InMemoryTableScan [group#94006308, annual_ret#94006310, Sharpe_ret#94006312, PctPos_ret#94006313, annual_resret#94006316, Sharpe_resret#94006318, PctPos_resret#94006319, annual_retnet#94006322, Sharpe_retnet#94006324, PctPos_retnet#94006325], [isnotnull(group#94006308)]\n : +- InMemoryRelation [group#94006308, annual_bmret#94006309, annual_ret#94006310, std_ret#94006311, Sharpe_ret#94006312, PctPos_ret#94006313, TR_ret#94006314, IR_ret#94006315, annual_resret#94006316, std_resret#94006317, Sharpe_res... [3610431] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286686 {
label="InMemoryTableScan";
3615329 [labelType="html" label="MapPartitionsRDD [3615329]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615330 [labelType="html" label="MapPartitionsRDD [3615330]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615331 [labelType="html" label="MapPartitionsRDD [3615331]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286685 {
label="CollectLimit";
3615332 [labelType="html" label="MapPartitionsRDD [3615332]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286687 {
label="mapPartitionsInternal";
3615333 [labelType="html" label="MapPartitionsRDD [3615333]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6286688 {
label="map";
3615334 [labelType="html" label="MapPartitionsRDD [3615334]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3605506->3605507;
3605507->3605508;
3605508->3605509;
3605509->3605510;
3605510->3610426;
3610426->3610427;
3610427->3610428;
3610428->3610429;
3610429->3610430;
3610430->3610431;
3610431->3615329;
3615329->3615330;
3615330->3615331;
3615331->3615332;
3615332->3615333;
3615333->3615334;
}
3605510
3610431