digraph G {
subgraph clusterstage_511806 {
label="Stage 511806";
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 cluster6287306 {
label="InMemoryTableScan";
3615654 [labelType="html" label="MapPartitionsRDD [3615654]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615655 [labelType="html" label="MapPartitionsRDD [3615655]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3615656 [labelType="html" label="MapPartitionsRDD [3615656]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287305 {
label="CollectLimit";
3615657 [labelType="html" label="MapPartitionsRDD [3615657]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287307 {
label="mapPartitionsInternal";
3615658 [labelType="html" label="MapPartitionsRDD [3615658]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6287308 {
label="map";
3615661 [labelType="html" label="MapPartitionsRDD [3615661]<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->3615654;
3615654->3615655;
3615655->3615656;
3615656->3615657;
3615657->3615658;
3615658->3615661;
}
3605510
3610431