== Physical Plan ==
CollectLimit (16)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- * Project (15)
+- * BroadcastHashJoin Inner BuildRight (14)
:- * Filter (7)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- * Project (6)
: +- Scan csv (5)
+- BroadcastExchange (13)
+- * Filter (12)
+- InMemoryTableScan (8)
+- InMemoryRelation (9)
+- * Project (11)
+- Scan csv (10)
(1) InMemoryTableScan
Output [11]: [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
Arguments: [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
(2) InMemoryRelation
Arguments: [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(2) Project [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
+- *(2) BroadcastHashJoin [group#93991496], [group#93875766], Inner, BuildRight, false
:- *(2) Filter isnotnull(group#93991496)
: +- InMemoryTableScan [group#93991496, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546], [isnotnull(group#93991496)]
: +- InMemoryRelation [group#93991496, annual_bmret#93991503, annual_ret#93991505, std_ret#93991510, Sharpe_ret#93991515, PctPos_ret#93991518, TR_ret#93991520, IR_ret#93991523, annual_resret#93991525, std_resret#93991527, Sharpe_resret#93991530, PctPos_resret#93991532, TR_resret#93991534, IR_resret#93991536, annual_retnet#93991538, std_retnet#93991542, Sharpe_retnet#93991545, PctPos_retnet#93991546, TR_retnet#93991547, IR_retnet#93991548, retIC#93991549, resretIC#93991550, turnover#93991551], StorageLevel(disk, memory, deserialized, 1 replicas)
: +- *(1) Project [CASE WHEN (group#93990807 = null) THEN null ELSE group#93990807 END AS group#93991496, CASE WHEN ((annual_bmret#93990808 = NA) OR (annual_bmret#93990808 = null)) THEN null ELSE cast(annual_bmret#93990808 as float) END AS annual_bmret#93991503, CASE WHEN (annual_ret#93990809 = null) THEN null ELSE annual_ret#93990809 END AS annual_ret#93991505, CASE WHEN ((std_ret#93990810 = NA) OR (std_ret#93990810 = null)) THEN null ELSE cast(std_ret#93990810 as float) END AS std_ret#93991510, CASE WHEN ((Sharpe_ret#93990811 = NA) OR (Sharpe_ret#93990811 = null)) THEN null ELSE cast(Sharpe_ret#93990811 as float) END AS Sharpe_ret#93991515, CASE WHEN ((PctPos_ret#93990812 = NA) OR (PctPos_ret#93990812 = null)) THEN null ELSE cast(PctPos_ret#93990812 as float) END AS PctPos_ret#93991518, CASE WHEN ((TR_ret#93990813 = NA) OR (TR_ret#93990813 = null)) THEN null ELSE cast(TR_ret#93990813 as float) END AS TR_ret#93991520, CASE WHEN ((IR_ret#93990814 = NA) OR (IR_ret#93990814 = null)) THEN null ELSE cast(IR_ret#93990814 as float) END AS IR_ret#93991523, CASE WHEN ((annual_resret#93990815 = NA) OR (annual_resret#93990815 = null)) THEN null ELSE cast(annual_resret#93990815 as float) END AS annual_resret#93991525, CASE WHEN ((std_resret#93990816 = NA) OR (std_resret#93990816 = null)) THEN null ELSE cast(std_resret#93990816 as float) END AS std_resret#93991527, CASE WHEN ((Sharpe_resret#93990817 = NA) OR (Sharpe_resret#93990817 = null)) THEN null ELSE cast(Sharpe_resret#93990817 as float) END AS Sharpe_resret#93991530, CASE WHEN ((PctPos_resret#93990818 = NA) OR (PctPos_resret#93990818 = null)) THEN null ELSE cast(PctPos_resret#93990818 as float) END AS PctPos_resret#93991532, CASE WHEN ((TR_resret#93990819 = NA) OR (TR_resret#93990819 = null)) THEN null ELSE cast(TR_resret#93990819 as float) END AS TR_resret#93991534, CASE WHEN ((IR_resret#93990820 = NA) OR (IR_resret#93990820 = null)) THEN null ELSE cast(IR_resret#93990820 as float) END AS IR_resret#93991536, CASE WHEN (annual_retnet#93990821 = null) THEN null ELSE annual_retnet#93990821 END AS annual_retnet#93991538, CASE WHEN ((std_retnet#93990822 = NA) OR (std_retnet#93990822 = null)) THEN null ELSE cast(std_retnet#93990822 as float) END AS std_retnet#93991542, CASE WHEN ((Sharpe_retnet#93990823 = NA) OR (Sharpe_retnet#93990823 = null)) THEN null ELSE cast(Sharpe_retnet#93990823 as float) END AS Sharpe_retnet#93991545, CASE WHEN ((PctPos_retnet#93990824 = NA) OR (PctPos_retnet#93990824 = null)) THEN null ELSE cast(PctPos_retnet#93990824 as float) END AS PctPos_retnet#93991546, CASE WHEN ((TR_retnet#93990825 = NA) OR (TR_retnet#93990825 = null)) THEN null ELSE cast(TR_retnet#93990825 as float) END AS TR_retnet#93991547, CASE WHEN ((IR_retnet#93990826 = NA) OR (IR_retnet#93990826 = null)) THEN null ELSE cast(IR_retnet#93990826 as float) END AS IR_retnet#93991548, CASE WHEN ((retIC#93990827 = NA) OR (retIC#93990827 = null)) THEN null ELSE cast(retIC#93990827 as float) END AS retIC#93991549, CASE WHEN ((resretIC#93990828 = NA) OR (resretIC#93990828 = null)) THEN null ELSE cast(resretIC#93990828 as float) END AS resretIC#93991550, CASE WHEN (turnover#93990829 = null) THEN null ELSE turnover#93990829 END AS turnover#93991551]
: +- FileScan csv [group#93990807,annual_bmret#93990808,annual_ret#93990809,std_ret#93990810,Sharpe_ret#93990811,PctPos_ret#93990812,TR_ret#93990813,IR_ret#93990814,annual_resret#93990815,std_resret#93990816,Sharpe_resret#93990817,PctPos_resret#93990818,TR_resret#93990819,IR_resret#93990820,annual_retnet#93990821,std_retnet#93990822,Sharpe_retnet#93990823,PctPos_retnet#93990824,TR_retnet#93990825,IR_retnet#93990826,retIC#93990827,resretIC#93990828,turnover#93990829] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<group:string,annual_bmret:string,annual_ret:string,std_ret:string,Sharpe_ret:string,PctPos...
+- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [id=#7504686]
+- *(1) Filter isnotnull(group#93875766)
+- InMemoryTableScan [group#93875766, Category#93875767, Label#93875768], [isnotnull(group#93875766)]
+- InMemoryRelation [group#93875766, Category#93875767, Label#93875768], StorageLevel(disk, memory, deserialized, 1 replicas)
+- *(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]
+- 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>
,None)
(3) InMemoryTableScan
Output [10]: [group#93991496, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
Arguments: [group#93991496, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546], [isnotnull(group#93991496)]
(4) InMemoryRelation
Arguments: [group#93991496, annual_bmret#93991503, annual_ret#93991505, std_ret#93991510, Sharpe_ret#93991515, PctPos_ret#93991518, TR_ret#93991520, IR_ret#93991523, annual_resret#93991525, std_resret#93991527, Sharpe_resret#93991530, PctPos_resret#93991532, TR_resret#93991534, IR_resret#93991536, annual_retnet#93991538, std_retnet#93991542, Sharpe_retnet#93991545, PctPos_retnet#93991546, TR_retnet#93991547, IR_retnet#93991548, retIC#93991549, resretIC#93991550, turnover#93991551], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN (group#93990807 = null) THEN null ELSE group#93990807 END AS group#93991496, CASE WHEN ((annual_bmret#93990808 = NA) OR (annual_bmret#93990808 = null)) THEN null ELSE cast(annual_bmret#93990808 as float) END AS annual_bmret#93991503, CASE WHEN (annual_ret#93990809 = null) THEN null ELSE annual_ret#93990809 END AS annual_ret#93991505, CASE WHEN ((std_ret#93990810 = NA) OR (std_ret#93990810 = null)) THEN null ELSE cast(std_ret#93990810 as float) END AS std_ret#93991510, CASE WHEN ((Sharpe_ret#93990811 = NA) OR (Sharpe_ret#93990811 = null)) THEN null ELSE cast(Sharpe_ret#93990811 as float) END AS Sharpe_ret#93991515, CASE WHEN ((PctPos_ret#93990812 = NA) OR (PctPos_ret#93990812 = null)) THEN null ELSE cast(PctPos_ret#93990812 as float) END AS PctPos_ret#93991518, CASE WHEN ((TR_ret#93990813 = NA) OR (TR_ret#93990813 = null)) THEN null ELSE cast(TR_ret#93990813 as float) END AS TR_ret#93991520, CASE WHEN ((IR_ret#93990814 = NA) OR (IR_ret#93990814 = null)) THEN null ELSE cast(IR_ret#93990814 as float) END AS IR_ret#93991523, CASE WHEN ((annual_resret#93990815 = NA) OR (annual_resret#93990815 = null)) THEN null ELSE cast(annual_resret#93990815 as float) END AS annual_resret#93991525, CASE WHEN ((std_resret#93990816 = NA) OR (std_resret#93990816 = null)) THEN null ELSE cast(std_resret#93990816 as float) END AS std_resret#93991527, CASE WHEN ((Sharpe_resret#93990817 = NA) OR (Sharpe_resret#93990817 = null)) THEN null ELSE cast(Sharpe_resret#93990817 as float) END AS Sharpe_resret#93991530, CASE WHEN ((PctPos_resret#93990818 = NA) OR (PctPos_resret#93990818 = null)) THEN null ELSE cast(PctPos_resret#93990818 as float) END AS PctPos_resret#93991532, CASE WHEN ((TR_resret#93990819 = NA) OR (TR_resret#93990819 = null)) THEN null ELSE cast(TR_resret#93990819 as float) END AS TR_resret#93991534, CASE WHEN ((IR_resret#93990820 = NA) OR (IR_resret#93990820 = null)) THEN null ELSE cast(IR_resret#93990820 as float) END AS IR_resret#93991536, CASE WHEN (annual_retnet#93990821 = null) THEN null ELSE annual_retnet#93990821 END AS annual_retnet#93991538, CASE WHEN ((std_retnet#93990822 = NA) OR (std_retnet#93990822 = null)) THEN null ELSE cast(std_retnet#93990822 as float) END AS std_retnet#93991542, CASE WHEN ((Sharpe_retnet#93990823 = NA) OR (Sharpe_retnet#93990823 = null)) THEN null ELSE cast(Sharpe_retnet#93990823 as float) END AS Sharpe_retnet#93991545, CASE WHEN ((PctPos_retnet#93990824 = NA) OR (PctPos_retnet#93990824 = null)) THEN null ELSE cast(PctPos_retnet#93990824 as float) END AS PctPos_retnet#93991546, CASE WHEN ((TR_retnet#93990825 = NA) OR (TR_retnet#93990825 = null)) THEN null ELSE cast(TR_retnet#93990825 as float) END AS TR_retnet#93991547, CASE WHEN ((IR_retnet#93990826 = NA) OR (IR_retnet#93990826 = null)) THEN null ELSE cast(IR_retnet#93990826 as float) END AS IR_retnet#93991548, CASE WHEN ((retIC#93990827 = NA) OR (retIC#93990827 = null)) THEN null ELSE cast(retIC#93990827 as float) END AS retIC#93991549, CASE WHEN ((resretIC#93990828 = NA) OR (resretIC#93990828 = null)) THEN null ELSE cast(resretIC#93990828 as float) END AS resretIC#93991550, CASE WHEN (turnover#93990829 = null) THEN null ELSE turnover#93990829 END AS turnover#93991551]
+- FileScan csv [group#93990807,annual_bmret#93990808,annual_ret#93990809,std_ret#93990810,Sharpe_ret#93990811,PctPos_ret#93990812,TR_ret#93990813,IR_ret#93990814,annual_resret#93990815,std_resret#93990816,Sharpe_resret#93990817,PctPos_resret#93990818,TR_resret#93990819,IR_resret#93990820,annual_retnet#93990821,std_retnet#93990822,Sharpe_retnet#93990823,PctPos_retnet#93990824,TR_retnet#93990825,IR_retnet#93990826,retIC#93990827,resretIC#93990828,turnover#93990829] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<group:string,annual_bmret:string,annual_ret:string,std_ret:string,Sharpe_ret:string,PctPos...
,None)
(5) Scan csv
Output [23]: [group#93990807, annual_bmret#93990808, annual_ret#93990809, std_ret#93990810, Sharpe_ret#93990811, PctPos_ret#93990812, TR_ret#93990813, IR_ret#93990814, annual_resret#93990815, std_resret#93990816, Sharpe_resret#93990817, PctPos_resret#93990818, TR_resret#93990819, IR_resret#93990820, annual_retnet#93990821, std_retnet#93990822, Sharpe_retnet#93990823, PctPos_retnet#93990824, TR_retnet#93990825, IR_retnet#93990826, retIC#93990827, resretIC#93990828, turnover#93990829]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/output/estimize_signal_history/estimizesignal_preearnings/REPORT_stats.csv]
ReadSchema: struct<group:string,annual_bmret:string,annual_ret:string,std_ret:string,Sharpe_ret:string,PctPos_ret:string,TR_ret:string,IR_ret:string,annual_resret:string,std_resret:string,Sharpe_resret:string,PctPos_resret:string,TR_resret:string,IR_resret:string,annual_retnet:string,std_retnet:string,Sharpe_retnet:string,PctPos_retnet:string,TR_retnet:string,IR_retnet:string,retIC:string,resretIC:string,turnover:string>
(6) Project [codegen id : 1]
Output [23]: [CASE WHEN (group#93990807 = null) THEN null ELSE group#93990807 END AS group#93991496, CASE WHEN ((annual_bmret#93990808 = NA) OR (annual_bmret#93990808 = null)) THEN null ELSE cast(annual_bmret#93990808 as float) END AS annual_bmret#93991503, CASE WHEN (annual_ret#93990809 = null) THEN null ELSE annual_ret#93990809 END AS annual_ret#93991505, CASE WHEN ((std_ret#93990810 = NA) OR (std_ret#93990810 = null)) THEN null ELSE cast(std_ret#93990810 as float) END AS std_ret#93991510, CASE WHEN ((Sharpe_ret#93990811 = NA) OR (Sharpe_ret#93990811 = null)) THEN null ELSE cast(Sharpe_ret#93990811 as float) END AS Sharpe_ret#93991515, CASE WHEN ((PctPos_ret#93990812 = NA) OR (PctPos_ret#93990812 = null)) THEN null ELSE cast(PctPos_ret#93990812 as float) END AS PctPos_ret#93991518, CASE WHEN ((TR_ret#93990813 = NA) OR (TR_ret#93990813 = null)) THEN null ELSE cast(TR_ret#93990813 as float) END AS TR_ret#93991520, CASE WHEN ((IR_ret#93990814 = NA) OR (IR_ret#93990814 = null)) THEN null ELSE cast(IR_ret#93990814 as float) END AS IR_ret#93991523, CASE WHEN ((annual_resret#93990815 = NA) OR (annual_resret#93990815 = null)) THEN null ELSE cast(annual_resret#93990815 as float) END AS annual_resret#93991525, CASE WHEN ((std_resret#93990816 = NA) OR (std_resret#93990816 = null)) THEN null ELSE cast(std_resret#93990816 as float) END AS std_resret#93991527, CASE WHEN ((Sharpe_resret#93990817 = NA) OR (Sharpe_resret#93990817 = null)) THEN null ELSE cast(Sharpe_resret#93990817 as float) END AS Sharpe_resret#93991530, CASE WHEN ((PctPos_resret#93990818 = NA) OR (PctPos_resret#93990818 = null)) THEN null ELSE cast(PctPos_resret#93990818 as float) END AS PctPos_resret#93991532, CASE WHEN ((TR_resret#93990819 = NA) OR (TR_resret#93990819 = null)) THEN null ELSE cast(TR_resret#93990819 as float) END AS TR_resret#93991534, CASE WHEN ((IR_resret#93990820 = NA) OR (IR_resret#93990820 = null)) THEN null ELSE cast(IR_resret#93990820 as float) END AS IR_resret#93991536, CASE WHEN (annual_retnet#93990821 = null) THEN null ELSE annual_retnet#93990821 END AS annual_retnet#93991538, CASE WHEN ((std_retnet#93990822 = NA) OR (std_retnet#93990822 = null)) THEN null ELSE cast(std_retnet#93990822 as float) END AS std_retnet#93991542, CASE WHEN ((Sharpe_retnet#93990823 = NA) OR (Sharpe_retnet#93990823 = null)) THEN null ELSE cast(Sharpe_retnet#93990823 as float) END AS Sharpe_retnet#93991545, CASE WHEN ((PctPos_retnet#93990824 = NA) OR (PctPos_retnet#93990824 = null)) THEN null ELSE cast(PctPos_retnet#93990824 as float) END AS PctPos_retnet#93991546, CASE WHEN ((TR_retnet#93990825 = NA) OR (TR_retnet#93990825 = null)) THEN null ELSE cast(TR_retnet#93990825 as float) END AS TR_retnet#93991547, CASE WHEN ((IR_retnet#93990826 = NA) OR (IR_retnet#93990826 = null)) THEN null ELSE cast(IR_retnet#93990826 as float) END AS IR_retnet#93991548, CASE WHEN ((retIC#93990827 = NA) OR (retIC#93990827 = null)) THEN null ELSE cast(retIC#93990827 as float) END AS retIC#93991549, CASE WHEN ((resretIC#93990828 = NA) OR (resretIC#93990828 = null)) THEN null ELSE cast(resretIC#93990828 as float) END AS resretIC#93991550, CASE WHEN (turnover#93990829 = null) THEN null ELSE turnover#93990829 END AS turnover#93991551]
Input [23]: [group#93990807, annual_bmret#93990808, annual_ret#93990809, std_ret#93990810, Sharpe_ret#93990811, PctPos_ret#93990812, TR_ret#93990813, IR_ret#93990814, annual_resret#93990815, std_resret#93990816, Sharpe_resret#93990817, PctPos_resret#93990818, TR_resret#93990819, IR_resret#93990820, annual_retnet#93990821, std_retnet#93990822, Sharpe_retnet#93990823, PctPos_retnet#93990824, TR_retnet#93990825, IR_retnet#93990826, retIC#93990827, resretIC#93990828, turnover#93990829]
(7) Filter [codegen id : 2]
Input [10]: [group#93991496, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
Condition : isnotnull(group#93991496)
(8) InMemoryTableScan
Output [3]: [group#93875766, Category#93875767, Label#93875768]
Arguments: [group#93875766, Category#93875767, Label#93875768], [isnotnull(group#93875766)]
(9) InMemoryRelation
Arguments: [group#93875766, Category#93875767, Label#93875768], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(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]
+- 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>
,None)
(10) Scan csv
Output [3]: [group#93875754, Category#93875755, Label#93875756]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/common/map_stats.csv]
ReadSchema: struct<group:string,Category:string,Label:string>
(11) Project [codegen id : 1]
Output [3]: [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]
Input [3]: [group#93875754, Category#93875755, Label#93875756]
(12) Filter [codegen id : 1]
Input [3]: [group#93875766, Category#93875767, Label#93875768]
Condition : isnotnull(group#93875766)
(13) BroadcastExchange
Input [3]: [group#93875766, Category#93875767, Label#93875768]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [id=#7504686]
(14) BroadcastHashJoin [codegen id : 2]
Left keys [1]: [group#93991496]
Right keys [1]: [group#93875766]
Join condition: None
(15) Project [codegen id : 2]
Output [11]: [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
Input [13]: [group#93991496, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546, group#93875766, Category#93875767, Label#93875768]
(16) CollectLimit
Input [11]: [Category#93875767, Label#93875768, annual_ret#93991505, Sharpe_ret#93991515, PctPos_ret#93991518, annual_resret#93991525, Sharpe_resret#93991530, PctPos_resret#93991532, annual_retnet#93991538, Sharpe_retnet#93991545, PctPos_retnet#93991546]
Arguments: 1000000