• Submitted Time: 2025/08/01 15:44:47
• Duration: 56 ms
• Succeeded Jobs: 330114 

== Physical Plan ==
CollectLimit (19)
+- * ColumnarToRow (18)
   +- InMemoryTableScan (1)
         +- InMemoryRelation (2)
               +- * Project (17)
                  +- * BroadcastNestedLoopJoin Cross BuildRight (16)
                     :- * Project (9)
                     :  +- * Filter (8)
                     :     +- * ColumnarToRow (7)
                     :        +- InMemoryTableScan (3)
                     :              +- InMemoryRelation (4)
                     :                    +- * Project (6)
                     :                       +- Scan csv  (5)
                     +- BroadcastExchange (15)
                        +- * Project (14)
                           +- * Filter (13)
                              +- * ColumnarToRow (12)
                                 +- InMemoryTableScan (10)
                                       +- InMemoryRelation (11)
                                             +- * Project (6)
                                                +- Scan csv  (5)


(1) InMemoryTableScan
Output [3]: [ret_large#93999304, ret_small#93999306, differential#93999392]
Arguments: [ret_large#93999304, ret_small#93999306, differential#93999392]

(2) InMemoryRelation
Arguments: [ret_large#93999304, ret_small#93999306, differential#93999392], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(2) Project [ret_large#93999304, ret_small#93999306, (ret_large#93999304 - ret_small#93999306) AS differential#93999392]
+- *(2) BroadcastNestedLoopJoin BuildRight, Cross
   :- *(2) Project [annual_ret#93996140 AS ret_large#93999304]
   :  +- *(2) Filter (isnotnull(cap#93996101) AND (cap#93996101 = 1.0))
   :     +- *(2) ColumnarToRow
   :        +- InMemoryTableScan [annual_ret#93996140, cap#93996101], [isnotnull(cap#93996101), (cap#93996101 = 1.0)]
   :              +- InMemoryRelation [cap#93996101, retIC#93996104, resretIC#93996107, numcos#93996111, numdates#93996114, annual_bmret#93996138, annual_ret#93996140, std_ret#93996142, Sharpe_ret#93996144, PctPos_ret#93996201, TR_ret#93996215, IR_ret#93996217, annual_resret#93996218, std_resret#93996231, Sharpe_resret#93996232, PctPos_resret#93996233, TR_resret#93996234, IR_resret#93996246, annual_retnet#93996248, std_retnet#93996249, Sharpe_retnet#93996250, PctPos_retnet#93996251, TR_retnet#93996264, IR_retnet#93996265, ... 2 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)
   :                    +- *(1) Project [CASE WHEN ((cap#93995882 = NA) OR (cap#93995882 = null)) THEN null ELSE cast(cap#93995882 as float) END AS cap#93996101, CASE WHEN ((retIC#93995883 = NA) OR (retIC#93995883 = null)) THEN null ELSE cast(retIC#93995883 as float) END AS retIC#93996104, CASE WHEN ((resretIC#93995884 = NA) OR (resretIC#93995884 = null)) THEN null ELSE cast(resretIC#93995884 as float) END AS resretIC#93996107, CASE WHEN ((numcos#93995885 = NA) OR (numcos#93995885 = null)) THEN null ELSE cast(numcos#93995885 as float) END AS numcos#93996111, CASE WHEN ((numdates#93995886 = NA) OR (numdates#93995886 = null)) THEN null ELSE cast(numdates#93995886 as int) END AS numdates#93996114, CASE WHEN ((annual_bmret#93995887 = NA) OR (annual_bmret#93995887 = null)) THEN null ELSE cast(annual_bmret#93995887 as float) END AS annual_bmret#93996138, CASE WHEN ((annual_ret#93995888 = NA) OR (annual_ret#93995888 = null)) THEN null ELSE cast(annual_ret#93995888 as float) END AS annual_ret#93996140, CASE WHEN ((std_ret#93995889 = NA) OR (std_ret#93995889 = null)) THEN null ELSE cast(std_ret#93995889 as float) END AS std_ret#93996142, CASE WHEN ((Sharpe_ret#93995890 = NA) OR (Sharpe_ret#93995890 = null)) THEN null ELSE cast(Sharpe_ret#93995890 as float) END AS Sharpe_ret#93996144, CASE WHEN ((PctPos_ret#93995891 = NA) OR (PctPos_ret#93995891 = null)) THEN null ELSE cast(PctPos_ret#93995891 as float) END AS PctPos_ret#93996201, CASE WHEN ((TR_ret#93995892 = NA) OR (TR_ret#93995892 = null)) THEN null ELSE cast(TR_ret#93995892 as float) END AS TR_ret#93996215, CASE WHEN ((IR_ret#93995893 = NA) OR (IR_ret#93995893 = null)) THEN null ELSE cast(IR_ret#93995893 as float) END AS IR_ret#93996217, CASE WHEN ((annual_resret#93995894 = NA) OR (annual_resret#93995894 = null)) THEN null ELSE cast(annual_resret#93995894 as float) END AS annual_resret#93996218, CASE WHEN ((std_resret#93995895 = NA) OR (std_resret#93995895 = null)) THEN null ELSE cast(std_resret#93995895 as float) END AS std_resret#93996231, CASE WHEN ((Sharpe_resret#93995896 = NA) OR (Sharpe_resret#93995896 = null)) THEN null ELSE cast(Sharpe_resret#93995896 as float) END AS Sharpe_resret#93996232, CASE WHEN ((PctPos_resret#93995897 = NA) OR (PctPos_resret#93995897 = null)) THEN null ELSE cast(PctPos_resret#93995897 as float) END AS PctPos_resret#93996233, CASE WHEN ((TR_resret#93995898 = NA) OR (TR_resret#93995898 = null)) THEN null ELSE cast(TR_resret#93995898 as float) END AS TR_resret#93996234, CASE WHEN ((IR_resret#93995899 = NA) OR (IR_resret#93995899 = null)) THEN null ELSE cast(IR_resret#93995899 as float) END AS IR_resret#93996246, CASE WHEN ((annual_retnet#93995900 = NA) OR (annual_retnet#93995900 = null)) THEN null ELSE cast(annual_retnet#93995900 as float) END AS annual_retnet#93996248, CASE WHEN ((std_retnet#93995901 = NA) OR (std_retnet#93995901 = null)) THEN null ELSE cast(std_retnet#93995901 as float) END AS std_retnet#93996249, CASE WHEN ((Sharpe_retnet#93995902 = NA) OR (Sharpe_retnet#93995902 = null)) THEN null ELSE cast(Sharpe_retnet#93995902 as float) END AS Sharpe_retnet#93996250, CASE WHEN ((PctPos_retnet#93995903 = NA) OR (PctPos_retnet#93995903 = null)) THEN null ELSE cast(PctPos_retnet#93995903 as float) END AS PctPos_retnet#93996251, CASE WHEN ((TR_retnet#93995904 = NA) OR (TR_retnet#93995904 = null)) THEN null ELSE cast(TR_retnet#93995904 as float) END AS TR_retnet#93996264, CASE WHEN ((IR_retnet#93995905 = NA) OR (IR_retnet#93995905 = null)) THEN null ELSE cast(IR_retnet#93995905 as float) END AS IR_retnet#93996265, ... 2 more fields]
   :                       +- FileScan csv [cap#93995882,retIC#93995883,resretIC#93995884,numcos#93995885,numdates#93995886,annual_bmret#93995887,annual_ret#93995888,std_ret#93995889,Sharpe_ret#93995890,PctPos_ret#93995891,TR_ret#93995892,IR_ret#93995893,annual_resret#93995894,std_resret#93995895,Sharpe_resret#93995896,PctPos_resret#93995897,TR_resret#93995898,IR_resret#93995899,annual_retnet#93995900,std_retnet#93995901,Sharpe_retnet#93995902,PctPos_retnet#93995903,TR_retnet#93995904,IR_retnet#93995905,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
   +- BroadcastExchange IdentityBroadcastMode, [id=#7505280]
      +- *(1) Project [annual_ret#93996140 AS ret_small#93999306]
         +- *(1) Filter (isnotnull(cap#93996101) AND (cap#93996101 = 3.0))
            +- *(1) ColumnarToRow
               +- InMemoryTableScan [annual_ret#93996140, cap#93996101], [isnotnull(cap#93996101), (cap#93996101 = 3.0)]
                     +- InMemoryRelation [cap#93996101, retIC#93996104, resretIC#93996107, numcos#93996111, numdates#93996114, annual_bmret#93996138, annual_ret#93996140, std_ret#93996142, Sharpe_ret#93996144, PctPos_ret#93996201, TR_ret#93996215, IR_ret#93996217, annual_resret#93996218, std_resret#93996231, Sharpe_resret#93996232, PctPos_resret#93996233, TR_resret#93996234, IR_resret#93996246, annual_retnet#93996248, std_retnet#93996249, Sharpe_retnet#93996250, PctPos_retnet#93996251, TR_retnet#93996264, IR_retnet#93996265, ... 2 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)
                           +- *(1) Project [CASE WHEN ((cap#93995882 = NA) OR (cap#93995882 = null)) THEN null ELSE cast(cap#93995882 as float) END AS cap#93996101, CASE WHEN ((retIC#93995883 = NA) OR (retIC#93995883 = null)) THEN null ELSE cast(retIC#93995883 as float) END AS retIC#93996104, CASE WHEN ((resretIC#93995884 = NA) OR (resretIC#93995884 = null)) THEN null ELSE cast(resretIC#93995884 as float) END AS resretIC#93996107, CASE WHEN ((numcos#93995885 = NA) OR (numcos#93995885 = null)) THEN null ELSE cast(numcos#93995885 as float) END AS numcos#93996111, CASE WHEN ((numdates#93995886 = NA) OR (numdates#93995886 = null)) THEN null ELSE cast(numdates#93995886 as int) END AS numdates#93996114, CASE WHEN ((annual_bmret#93995887 = NA) OR (annual_bmret#93995887 = null)) THEN null ELSE cast(annual_bmret#93995887 as float) END AS annual_bmret#93996138, CASE WHEN ((annual_ret#93995888 = NA) OR (annual_ret#93995888 = null)) THEN null ELSE cast(annual_ret#93995888 as float) END AS annual_ret#93996140, CASE WHEN ((std_ret#93995889 = NA) OR (std_ret#93995889 = null)) THEN null ELSE cast(std_ret#93995889 as float) END AS std_ret#93996142, CASE WHEN ((Sharpe_ret#93995890 = NA) OR (Sharpe_ret#93995890 = null)) THEN null ELSE cast(Sharpe_ret#93995890 as float) END AS Sharpe_ret#93996144, CASE WHEN ((PctPos_ret#93995891 = NA) OR (PctPos_ret#93995891 = null)) THEN null ELSE cast(PctPos_ret#93995891 as float) END AS PctPos_ret#93996201, CASE WHEN ((TR_ret#93995892 = NA) OR (TR_ret#93995892 = null)) THEN null ELSE cast(TR_ret#93995892 as float) END AS TR_ret#93996215, CASE WHEN ((IR_ret#93995893 = NA) OR (IR_ret#93995893 = null)) THEN null ELSE cast(IR_ret#93995893 as float) END AS IR_ret#93996217, CASE WHEN ((annual_resret#93995894 = NA) OR (annual_resret#93995894 = null)) THEN null ELSE cast(annual_resret#93995894 as float) END AS annual_resret#93996218, CASE WHEN ((std_resret#93995895 = NA) OR (std_resret#93995895 = null)) THEN null ELSE cast(std_resret#93995895 as float) END AS std_resret#93996231, CASE WHEN ((Sharpe_resret#93995896 = NA) OR (Sharpe_resret#93995896 = null)) THEN null ELSE cast(Sharpe_resret#93995896 as float) END AS Sharpe_resret#93996232, CASE WHEN ((PctPos_resret#93995897 = NA) OR (PctPos_resret#93995897 = null)) THEN null ELSE cast(PctPos_resret#93995897 as float) END AS PctPos_resret#93996233, CASE WHEN ((TR_resret#93995898 = NA) OR (TR_resret#93995898 = null)) THEN null ELSE cast(TR_resret#93995898 as float) END AS TR_resret#93996234, CASE WHEN ((IR_resret#93995899 = NA) OR (IR_resret#93995899 = null)) THEN null ELSE cast(IR_resret#93995899 as float) END AS IR_resret#93996246, CASE WHEN ((annual_retnet#93995900 = NA) OR (annual_retnet#93995900 = null)) THEN null ELSE cast(annual_retnet#93995900 as float) END AS annual_retnet#93996248, CASE WHEN ((std_retnet#93995901 = NA) OR (std_retnet#93995901 = null)) THEN null ELSE cast(std_retnet#93995901 as float) END AS std_retnet#93996249, CASE WHEN ((Sharpe_retnet#93995902 = NA) OR (Sharpe_retnet#93995902 = null)) THEN null ELSE cast(Sharpe_retnet#93995902 as float) END AS Sharpe_retnet#93996250, CASE WHEN ((PctPos_retnet#93995903 = NA) OR (PctPos_retnet#93995903 = null)) THEN null ELSE cast(PctPos_retnet#93995903 as float) END AS PctPos_retnet#93996251, CASE WHEN ((TR_retnet#93995904 = NA) OR (TR_retnet#93995904 = null)) THEN null ELSE cast(TR_retnet#93995904 as float) END AS TR_retnet#93996264, CASE WHEN ((IR_retnet#93995905 = NA) OR (IR_retnet#93995905 = null)) THEN null ELSE cast(IR_retnet#93995905 as float) END AS IR_retnet#93996265, ... 2 more fields]
                              +- FileScan csv [cap#93995882,retIC#93995883,resretIC#93995884,numcos#93995885,numdates#93995886,annual_bmret#93995887,annual_ret#93995888,std_ret#93995889,Sharpe_ret#93995890,PctPos_ret#93995891,TR_ret#93995892,IR_ret#93995893,annual_resret#93995894,std_resret#93995895,Sharpe_resret#93995896,PctPos_resret#93995897,TR_resret#93995898,IR_resret#93995899,annual_retnet#93995900,std_retnet#93995901,Sharpe_retnet#93995902,PctPos_retnet#93995903,TR_retnet#93995904,IR_retnet#93995905,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
,None)

(3) InMemoryTableScan
Output [2]: [annual_ret#93996140, cap#93996101]
Arguments: [annual_ret#93996140, cap#93996101], [isnotnull(cap#93996101), (cap#93996101 = 1.0)]

(4) InMemoryRelation
Arguments: [cap#93996101, retIC#93996104, resretIC#93996107, numcos#93996111, numdates#93996114, annual_bmret#93996138, annual_ret#93996140, std_ret#93996142, Sharpe_ret#93996144, PctPos_ret#93996201, TR_ret#93996215, IR_ret#93996217, annual_resret#93996218, std_resret#93996231, Sharpe_resret#93996232, PctPos_resret#93996233, TR_resret#93996234, IR_resret#93996246, annual_retnet#93996248, std_retnet#93996249, Sharpe_retnet#93996250, PctPos_retnet#93996251, TR_retnet#93996264, IR_retnet#93996265, ... 2 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN ((cap#93995882 = NA) OR (cap#93995882 = null)) THEN null ELSE cast(cap#93995882 as float) END AS cap#93996101, CASE WHEN ((retIC#93995883 = NA) OR (retIC#93995883 = null)) THEN null ELSE cast(retIC#93995883 as float) END AS retIC#93996104, CASE WHEN ((resretIC#93995884 = NA) OR (resretIC#93995884 = null)) THEN null ELSE cast(resretIC#93995884 as float) END AS resretIC#93996107, CASE WHEN ((numcos#93995885 = NA) OR (numcos#93995885 = null)) THEN null ELSE cast(numcos#93995885 as float) END AS numcos#93996111, CASE WHEN ((numdates#93995886 = NA) OR (numdates#93995886 = null)) THEN null ELSE cast(numdates#93995886 as int) END AS numdates#93996114, CASE WHEN ((annual_bmret#93995887 = NA) OR (annual_bmret#93995887 = null)) THEN null ELSE cast(annual_bmret#93995887 as float) END AS annual_bmret#93996138, CASE WHEN ((annual_ret#93995888 = NA) OR (annual_ret#93995888 = null)) THEN null ELSE cast(annual_ret#93995888 as float) END AS annual_ret#93996140, CASE WHEN ((std_ret#93995889 = NA) OR (std_ret#93995889 = null)) THEN null ELSE cast(std_ret#93995889 as float) END AS std_ret#93996142, CASE WHEN ((Sharpe_ret#93995890 = NA) OR (Sharpe_ret#93995890 = null)) THEN null ELSE cast(Sharpe_ret#93995890 as float) END AS Sharpe_ret#93996144, CASE WHEN ((PctPos_ret#93995891 = NA) OR (PctPos_ret#93995891 = null)) THEN null ELSE cast(PctPos_ret#93995891 as float) END AS PctPos_ret#93996201, CASE WHEN ((TR_ret#93995892 = NA) OR (TR_ret#93995892 = null)) THEN null ELSE cast(TR_ret#93995892 as float) END AS TR_ret#93996215, CASE WHEN ((IR_ret#93995893 = NA) OR (IR_ret#93995893 = null)) THEN null ELSE cast(IR_ret#93995893 as float) END AS IR_ret#93996217, CASE WHEN ((annual_resret#93995894 = NA) OR (annual_resret#93995894 = null)) THEN null ELSE cast(annual_resret#93995894 as float) END AS annual_resret#93996218, CASE WHEN ((std_resret#93995895 = NA) OR (std_resret#93995895 = null)) THEN null ELSE cast(std_resret#93995895 as float) END AS std_resret#93996231, CASE WHEN ((Sharpe_resret#93995896 = NA) OR (Sharpe_resret#93995896 = null)) THEN null ELSE cast(Sharpe_resret#93995896 as float) END AS Sharpe_resret#93996232, CASE WHEN ((PctPos_resret#93995897 = NA) OR (PctPos_resret#93995897 = null)) THEN null ELSE cast(PctPos_resret#93995897 as float) END AS PctPos_resret#93996233, CASE WHEN ((TR_resret#93995898 = NA) OR (TR_resret#93995898 = null)) THEN null ELSE cast(TR_resret#93995898 as float) END AS TR_resret#93996234, CASE WHEN ((IR_resret#93995899 = NA) OR (IR_resret#93995899 = null)) THEN null ELSE cast(IR_resret#93995899 as float) END AS IR_resret#93996246, CASE WHEN ((annual_retnet#93995900 = NA) OR (annual_retnet#93995900 = null)) THEN null ELSE cast(annual_retnet#93995900 as float) END AS annual_retnet#93996248, CASE WHEN ((std_retnet#93995901 = NA) OR (std_retnet#93995901 = null)) THEN null ELSE cast(std_retnet#93995901 as float) END AS std_retnet#93996249, CASE WHEN ((Sharpe_retnet#93995902 = NA) OR (Sharpe_retnet#93995902 = null)) THEN null ELSE cast(Sharpe_retnet#93995902 as float) END AS Sharpe_retnet#93996250, CASE WHEN ((PctPos_retnet#93995903 = NA) OR (PctPos_retnet#93995903 = null)) THEN null ELSE cast(PctPos_retnet#93995903 as float) END AS PctPos_retnet#93996251, CASE WHEN ((TR_retnet#93995904 = NA) OR (TR_retnet#93995904 = null)) THEN null ELSE cast(TR_retnet#93995904 as float) END AS TR_retnet#93996264, CASE WHEN ((IR_retnet#93995905 = NA) OR (IR_retnet#93995905 = null)) THEN null ELSE cast(IR_retnet#93995905 as float) END AS IR_retnet#93996265, ... 2 more fields]
+- FileScan csv [cap#93995882,retIC#93995883,resretIC#93995884,numcos#93995885,numdates#93995886,annual_bmret#93995887,annual_ret#93995888,std_ret#93995889,Sharpe_ret#93995890,PctPos_ret#93995891,TR_ret#93995892,IR_ret#93995893,annual_resret#93995894,std_resret#93995895,Sharpe_resret#93995896,PctPos_resret#93995897,TR_resret#93995898,IR_resret#93995899,annual_retnet#93995900,std_retnet#93995901,Sharpe_retnet#93995902,PctPos_retnet#93995903,TR_retnet#93995904,IR_retnet#93995905,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
,None)

(5) Scan csv 
Output [26]: [cap#93995882, retIC#93995883, resretIC#93995884, numcos#93995885, numdates#93995886, annual_bmret#93995887, annual_ret#93995888, std_ret#93995889, Sharpe_ret#93995890, PctPos_ret#93995891, TR_ret#93995892, IR_ret#93995893, annual_resret#93995894, std_resret#93995895, Sharpe_resret#93995896, PctPos_resret#93995897, TR_resret#93995898, IR_resret#93995899, annual_retnet#93995900, std_retnet#93995901, Sharpe_retnet#93995902, PctPos_retnet#93995903, TR_retnet#93995904, IR_retnet#93995905, turnover#93995906, coverage#93995907]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/output/estimize_signal_history/estimizesignal_preearnings/stats_cap.csv]
ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates: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,turnover:string,coverage:string>

(6) Project [codegen id : 1]
Output [26]: [CASE WHEN ((cap#93995882 = NA) OR (cap#93995882 = null)) THEN null ELSE cast(cap#93995882 as float) END AS cap#93996101, CASE WHEN ((retIC#93995883 = NA) OR (retIC#93995883 = null)) THEN null ELSE cast(retIC#93995883 as float) END AS retIC#93996104, CASE WHEN ((resretIC#93995884 = NA) OR (resretIC#93995884 = null)) THEN null ELSE cast(resretIC#93995884 as float) END AS resretIC#93996107, CASE WHEN ((numcos#93995885 = NA) OR (numcos#93995885 = null)) THEN null ELSE cast(numcos#93995885 as float) END AS numcos#93996111, CASE WHEN ((numdates#93995886 = NA) OR (numdates#93995886 = null)) THEN null ELSE cast(numdates#93995886 as int) END AS numdates#93996114, CASE WHEN ((annual_bmret#93995887 = NA) OR (annual_bmret#93995887 = null)) THEN null ELSE cast(annual_bmret#93995887 as float) END AS annual_bmret#93996138, CASE WHEN ((annual_ret#93995888 = NA) OR (annual_ret#93995888 = null)) THEN null ELSE cast(annual_ret#93995888 as float) END AS annual_ret#93996140, CASE WHEN ((std_ret#93995889 = NA) OR (std_ret#93995889 = null)) THEN null ELSE cast(std_ret#93995889 as float) END AS std_ret#93996142, CASE WHEN ((Sharpe_ret#93995890 = NA) OR (Sharpe_ret#93995890 = null)) THEN null ELSE cast(Sharpe_ret#93995890 as float) END AS Sharpe_ret#93996144, CASE WHEN ((PctPos_ret#93995891 = NA) OR (PctPos_ret#93995891 = null)) THEN null ELSE cast(PctPos_ret#93995891 as float) END AS PctPos_ret#93996201, CASE WHEN ((TR_ret#93995892 = NA) OR (TR_ret#93995892 = null)) THEN null ELSE cast(TR_ret#93995892 as float) END AS TR_ret#93996215, CASE WHEN ((IR_ret#93995893 = NA) OR (IR_ret#93995893 = null)) THEN null ELSE cast(IR_ret#93995893 as float) END AS IR_ret#93996217, CASE WHEN ((annual_resret#93995894 = NA) OR (annual_resret#93995894 = null)) THEN null ELSE cast(annual_resret#93995894 as float) END AS annual_resret#93996218, CASE WHEN ((std_resret#93995895 = NA) OR (std_resret#93995895 = null)) THEN null ELSE cast(std_resret#93995895 as float) END AS std_resret#93996231, CASE WHEN ((Sharpe_resret#93995896 = NA) OR (Sharpe_resret#93995896 = null)) THEN null ELSE cast(Sharpe_resret#93995896 as float) END AS Sharpe_resret#93996232, CASE WHEN ((PctPos_resret#93995897 = NA) OR (PctPos_resret#93995897 = null)) THEN null ELSE cast(PctPos_resret#93995897 as float) END AS PctPos_resret#93996233, CASE WHEN ((TR_resret#93995898 = NA) OR (TR_resret#93995898 = null)) THEN null ELSE cast(TR_resret#93995898 as float) END AS TR_resret#93996234, CASE WHEN ((IR_resret#93995899 = NA) OR (IR_resret#93995899 = null)) THEN null ELSE cast(IR_resret#93995899 as float) END AS IR_resret#93996246, CASE WHEN ((annual_retnet#93995900 = NA) OR (annual_retnet#93995900 = null)) THEN null ELSE cast(annual_retnet#93995900 as float) END AS annual_retnet#93996248, CASE WHEN ((std_retnet#93995901 = NA) OR (std_retnet#93995901 = null)) THEN null ELSE cast(std_retnet#93995901 as float) END AS std_retnet#93996249, CASE WHEN ((Sharpe_retnet#93995902 = NA) OR (Sharpe_retnet#93995902 = null)) THEN null ELSE cast(Sharpe_retnet#93995902 as float) END AS Sharpe_retnet#93996250, CASE WHEN ((PctPos_retnet#93995903 = NA) OR (PctPos_retnet#93995903 = null)) THEN null ELSE cast(PctPos_retnet#93995903 as float) END AS PctPos_retnet#93996251, CASE WHEN ((TR_retnet#93995904 = NA) OR (TR_retnet#93995904 = null)) THEN null ELSE cast(TR_retnet#93995904 as float) END AS TR_retnet#93996264, CASE WHEN ((IR_retnet#93995905 = NA) OR (IR_retnet#93995905 = null)) THEN null ELSE cast(IR_retnet#93995905 as float) END AS IR_retnet#93996265, CASE WHEN ((turnover#93995906 = NA) OR (turnover#93995906 = null)) THEN null ELSE cast(turnover#93995906 as float) END AS turnover#93996266, CASE WHEN ((coverage#93995907 = NA) OR (coverage#93995907 = null)) THEN null ELSE cast(coverage#93995907 as float) END AS coverage#93996279]
Input [26]: [cap#93995882, retIC#93995883, resretIC#93995884, numcos#93995885, numdates#93995886, annual_bmret#93995887, annual_ret#93995888, std_ret#93995889, Sharpe_ret#93995890, PctPos_ret#93995891, TR_ret#93995892, IR_ret#93995893, annual_resret#93995894, std_resret#93995895, Sharpe_resret#93995896, PctPos_resret#93995897, TR_resret#93995898, IR_resret#93995899, annual_retnet#93995900, std_retnet#93995901, Sharpe_retnet#93995902, PctPos_retnet#93995903, TR_retnet#93995904, IR_retnet#93995905, turnover#93995906, coverage#93995907]

(7) ColumnarToRow [codegen id : 2]
Input [2]: [annual_ret#93996140, cap#93996101]

(8) Filter [codegen id : 2]
Input [2]: [annual_ret#93996140, cap#93996101]
Condition : (isnotnull(cap#93996101) AND (cap#93996101 = 1.0))

(9) Project [codegen id : 2]
Output [1]: [annual_ret#93996140 AS ret_large#93999304]
Input [2]: [annual_ret#93996140, cap#93996101]

(10) InMemoryTableScan
Output [2]: [annual_ret#93996140, cap#93996101]
Arguments: [annual_ret#93996140, cap#93996101], [isnotnull(cap#93996101), (cap#93996101 = 3.0)]

(11) InMemoryRelation
Arguments: [cap#93996101, retIC#93996104, resretIC#93996107, numcos#93996111, numdates#93996114, annual_bmret#93996138, annual_ret#93996140, std_ret#93996142, Sharpe_ret#93996144, PctPos_ret#93996201, TR_ret#93996215, IR_ret#93996217, annual_resret#93996218, std_resret#93996231, Sharpe_resret#93996232, PctPos_resret#93996233, TR_resret#93996234, IR_resret#93996246, annual_retnet#93996248, std_retnet#93996249, Sharpe_retnet#93996250, PctPos_retnet#93996251, TR_retnet#93996264, IR_retnet#93996265, ... 2 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN ((cap#93995882 = NA) OR (cap#93995882 = null)) THEN null ELSE cast(cap#93995882 as float) END AS cap#93996101, CASE WHEN ((retIC#93995883 = NA) OR (retIC#93995883 = null)) THEN null ELSE cast(retIC#93995883 as float) END AS retIC#93996104, CASE WHEN ((resretIC#93995884 = NA) OR (resretIC#93995884 = null)) THEN null ELSE cast(resretIC#93995884 as float) END AS resretIC#93996107, CASE WHEN ((numcos#93995885 = NA) OR (numcos#93995885 = null)) THEN null ELSE cast(numcos#93995885 as float) END AS numcos#93996111, CASE WHEN ((numdates#93995886 = NA) OR (numdates#93995886 = null)) THEN null ELSE cast(numdates#93995886 as int) END AS numdates#93996114, CASE WHEN ((annual_bmret#93995887 = NA) OR (annual_bmret#93995887 = null)) THEN null ELSE cast(annual_bmret#93995887 as float) END AS annual_bmret#93996138, CASE WHEN ((annual_ret#93995888 = NA) OR (annual_ret#93995888 = null)) THEN null ELSE cast(annual_ret#93995888 as float) END AS annual_ret#93996140, CASE WHEN ((std_ret#93995889 = NA) OR (std_ret#93995889 = null)) THEN null ELSE cast(std_ret#93995889 as float) END AS std_ret#93996142, CASE WHEN ((Sharpe_ret#93995890 = NA) OR (Sharpe_ret#93995890 = null)) THEN null ELSE cast(Sharpe_ret#93995890 as float) END AS Sharpe_ret#93996144, CASE WHEN ((PctPos_ret#93995891 = NA) OR (PctPos_ret#93995891 = null)) THEN null ELSE cast(PctPos_ret#93995891 as float) END AS PctPos_ret#93996201, CASE WHEN ((TR_ret#93995892 = NA) OR (TR_ret#93995892 = null)) THEN null ELSE cast(TR_ret#93995892 as float) END AS TR_ret#93996215, CASE WHEN ((IR_ret#93995893 = NA) OR (IR_ret#93995893 = null)) THEN null ELSE cast(IR_ret#93995893 as float) END AS IR_ret#93996217, CASE WHEN ((annual_resret#93995894 = NA) OR (annual_resret#93995894 = null)) THEN null ELSE cast(annual_resret#93995894 as float) END AS annual_resret#93996218, CASE WHEN ((std_resret#93995895 = NA) OR (std_resret#93995895 = null)) THEN null ELSE cast(std_resret#93995895 as float) END AS std_resret#93996231, CASE WHEN ((Sharpe_resret#93995896 = NA) OR (Sharpe_resret#93995896 = null)) THEN null ELSE cast(Sharpe_resret#93995896 as float) END AS Sharpe_resret#93996232, CASE WHEN ((PctPos_resret#93995897 = NA) OR (PctPos_resret#93995897 = null)) THEN null ELSE cast(PctPos_resret#93995897 as float) END AS PctPos_resret#93996233, CASE WHEN ((TR_resret#93995898 = NA) OR (TR_resret#93995898 = null)) THEN null ELSE cast(TR_resret#93995898 as float) END AS TR_resret#93996234, CASE WHEN ((IR_resret#93995899 = NA) OR (IR_resret#93995899 = null)) THEN null ELSE cast(IR_resret#93995899 as float) END AS IR_resret#93996246, CASE WHEN ((annual_retnet#93995900 = NA) OR (annual_retnet#93995900 = null)) THEN null ELSE cast(annual_retnet#93995900 as float) END AS annual_retnet#93996248, CASE WHEN ((std_retnet#93995901 = NA) OR (std_retnet#93995901 = null)) THEN null ELSE cast(std_retnet#93995901 as float) END AS std_retnet#93996249, CASE WHEN ((Sharpe_retnet#93995902 = NA) OR (Sharpe_retnet#93995902 = null)) THEN null ELSE cast(Sharpe_retnet#93995902 as float) END AS Sharpe_retnet#93996250, CASE WHEN ((PctPos_retnet#93995903 = NA) OR (PctPos_retnet#93995903 = null)) THEN null ELSE cast(PctPos_retnet#93995903 as float) END AS PctPos_retnet#93996251, CASE WHEN ((TR_retnet#93995904 = NA) OR (TR_retnet#93995904 = null)) THEN null ELSE cast(TR_retnet#93995904 as float) END AS TR_retnet#93996264, CASE WHEN ((IR_retnet#93995905 = NA) OR (IR_retnet#93995905 = null)) THEN null ELSE cast(IR_retnet#93995905 as float) END AS IR_retnet#93996265, ... 2 more fields]
+- FileScan csv [cap#93995882,retIC#93995883,resretIC#93995884,numcos#93995885,numdates#93995886,annual_bmret#93995887,annual_ret#93995888,std_ret#93995889,Sharpe_ret#93995890,PctPos_ret#93995891,TR_ret#93995892,IR_ret#93995893,annual_resret#93995894,std_resret#93995895,Sharpe_resret#93995896,PctPos_resret#93995897,TR_resret#93995898,IR_resret#93995899,annual_retnet#93995900,std_retnet#93995901,Sharpe_retnet#93995902,PctPos_retnet#93995903,TR_retnet#93995904,IR_retnet#93995905,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/estimize_signal_histor..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
,None)

(12) ColumnarToRow [codegen id : 1]
Input [2]: [annual_ret#93996140, cap#93996101]

(13) Filter [codegen id : 1]
Input [2]: [annual_ret#93996140, cap#93996101]
Condition : (isnotnull(cap#93996101) AND (cap#93996101 = 3.0))

(14) Project [codegen id : 1]
Output [1]: [annual_ret#93996140 AS ret_small#93999306]
Input [2]: [annual_ret#93996140, cap#93996101]

(15) BroadcastExchange
Input [1]: [ret_small#93999306]
Arguments: IdentityBroadcastMode, [id=#7505280]

(16) BroadcastNestedLoopJoin [codegen id : 2]
Join condition: None

(17) Project [codegen id : 2]
Output [3]: [ret_large#93999304, ret_small#93999306, (ret_large#93999304 - ret_small#93999306) AS differential#93999392]
Input [2]: [ret_large#93999304, ret_small#93999306]

(18) ColumnarToRow [codegen id : 1]
Input [3]: [ret_large#93999304, ret_small#93999306, differential#93999392]

(19) CollectLimit
Input [3]: [ret_large#93999304, ret_small#93999306, differential#93999392]
Arguments: 10000