digraph G {
subgraph clusterstage_512880 {
label="Stage 512880";
subgraph cluster6287957 {
label="Scan csv ";
3616035 [labelType="html" label="FileScanRDD [3616035]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3616036 [labelType="html" label="MapPartitionsRDD [3616036]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6287953 {
label="WholeStageCodegen (1)";
3616037 [labelType="html" label="MapPartitionsRDD [3616037]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6287952 {
label="InMemoryTableScan";
3616038 [labelType="html" label="MapPartitionsRDD [3616038]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
3616039 [labelType="html" label="*(1) Project [CASE WHEN (group#94152498 = null) THEN null ELSE group#94152498 END AS group#94152510, CASE WHEN (Category#94152499 = null) THEN null ELSE Category#94152499 END AS Category#94152511, CASE WHEN (Label#94152500 = null) THEN null ELSE Label#94152500 END AS Label#94152512]\n+- FileScan csv [group#94152498,Category#94152499,Label#94152500] 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 [3616039] [Cached]<br>$anonfun$withThreadLocalCaptured$1 at FutureTask.java:264"];
}
subgraph cluster6301002 {
label="InMemoryTableScan";
3623523 [labelType="html" label="MapPartitionsRDD [3623523]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623524 [labelType="html" label="MapPartitionsRDD [3623524]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623525 [labelType="html" label="MapPartitionsRDD [3623525]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300977 {
label="WholeStageCodegen (2)";
3623526 [labelType="html" label="MapPartitionsRDD [3623526]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300976 {
label="InMemoryTableScan";
3623527 [labelType="html" label="MapPartitionsRDD [3623527]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623528 [labelType="html" label="*(2) Project [Category#94152530, Label#94152531, annual_ret#94348920, Sharpe_ret#94348923, PctPos_ret#94348924, annual_resret#94348927, Sharpe_resret#94348929, PctPos_resret#94348930, annual_retnet#94348933, Sharpe_retnet#94348957, PctPos_retnet#94348958]\n+- *(2) BroadcastHashJoin [group#94348918], [group#94152529], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [id=#7533179]\n : +- *(1) Filter isnotnull(group#94348918)\n : +- InMemoryTableScan [group#94348918, annual_ret#94348920, Sharpe_ret#94348923, PctPos_ret#94348924, annual_resret#94348927, Sharpe_resret#94348929, PctPos_resret#94348930, annual_retnet#94348933, Sharpe_retnet#94348957, PctPos_retnet#94348958], [isnotnull(group#94348918)]\n : +- InMemoryRelation [group#94348918, annual_bmret#94348919, annual_ret#94348920, std_ret#94348922, Sharpe_ret#94348923, PctPos_ret#94348924, TR_ret#94348925, IR_ret#94348926, annual_resret#94348927, std_resret#94348928, Sharpe_res... [3623528] [Cached]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623529 [labelType="html" label="MapPartitionsRDD [3623529]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623530 [labelType="html" label="MapPartitionsRDD [3623530]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
3623531 [labelType="html" label="MapPartitionsRDD [3623531]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6300975 {
label="CollectLimit";
3623532 [labelType="html" label="MapPartitionsRDD [3623532]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301003 {
label="mapPartitionsInternal";
3623533 [labelType="html" label="MapPartitionsRDD [3623533]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
subgraph cluster6301004 {
label="map";
3623534 [labelType="html" label="MapPartitionsRDD [3623534]<br>toLocalIterator at SparkDataStreamBuilder.scala:39"];
}
}
3616035->3616036;
3616036->3616037;
3616037->3616038;
3616038->3616039;
3616039->3623523;
3623523->3623524;
3623524->3623525;
3623525->3623526;
3623526->3623527;
3623527->3623528;
3623528->3623529;
3623529->3623530;
3623530->3623531;
3623531->3623532;
3623532->3623533;
3623533->3623534;
}
3616039
3623528