• Submitted Time: 2025/08/02 15:21:04
• Duration: 3 ms

== Physical Plan ==
CollectLimit (20)
+- InMemoryTableScan (1)
      +- InMemoryRelation (2)
            +- * Project (19)
               +- * Sort (18)
                  +- Exchange (17)
                     +- * Project (16)
                        +- * BroadcastHashJoin Inner BuildLeft (15)
                           :- BroadcastExchange (8)
                           :  +- * Filter (7)
                           :     +- InMemoryTableScan (3)
                           :           +- InMemoryRelation (4)
                           :                 +- * Project (6)
                           :                    +- Scan csv  (5)
                           +- * Project (14)
                              +- * Filter (13)
                                 +- InMemoryTableScan (9)
                                       +- InMemoryRelation (10)
                                             +- * Project (12)
                                                +- Scan csv  (11)


(1) InMemoryTableScan
Output [3]: [cap#94356862, turnover#94354290, days_hold#94356890]
Arguments: [cap#94356862, turnover#94354290, days_hold#94356890]

(2) InMemoryRelation
Arguments: [cap#94356862, turnover#94354290, days_hold#94356890], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(3) Project [cap#94356862, turnover#94354290, (1.0 / cast(turnover#94354290 as double)) AS days_hold#94356890]
+- *(3) Sort [cap_sort#94356773 ASC NULLS FIRST], true, 0
   +- Exchange rangepartitioning(cap_sort#94356773 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7533670]
      +- *(2) Project [turnover#94354290, cap_description#94356772 AS cap#94356862, cap_sort#94356773]
         +- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#94354236))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))], Inner, BuildLeft, false
            :- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7533662]
            :  +- *(1) Filter isnotnull(cap#94354236)
            :     +- InMemoryTableScan [cap#94354236, turnover#94354290], [isnotnull(cap#94354236)]
            :           +- InMemoryRelation [cap#94354236, retIC#94354237, resretIC#94354238, numcos#94354239, numdates#94354240, annual_bmret#94354241, annual_ret#94354242, std_ret#94354243, Sharpe_ret#94354244, PctPos_ret#94354262, TR_ret#94354263, IR_ret#94354264, annual_resret#94354276, std_resret#94354277, Sharpe_resret#94354280, PctPos_resret#94354281, TR_resret#94354282, IR_resret#94354283, annual_retnet#94354284, std_retnet#94354285, Sharpe_retnet#94354286, PctPos_retnet#94354287, TR_retnet#94354288, IR_retnet#94354289, ... 2 more fields], StorageLevel(disk, memory, deserialized, 1 replicas)
            :                 +- *(1) Project [CASE WHEN ((cap#94353974 = NA) OR (cap#94353974 = null)) THEN null ELSE cast(cap#94353974 as float) END AS cap#94354236, CASE WHEN ((retIC#94353975 = NA) OR (retIC#94353975 = null)) THEN null ELSE cast(retIC#94353975 as float) END AS retIC#94354237, CASE WHEN ((resretIC#94353976 = NA) OR (resretIC#94353976 = null)) THEN null ELSE cast(resretIC#94353976 as float) END AS resretIC#94354238, CASE WHEN ((numcos#94353977 = NA) OR (numcos#94353977 = null)) THEN null ELSE cast(numcos#94353977 as float) END AS numcos#94354239, CASE WHEN ((numdates#94353978 = NA) OR (numdates#94353978 = null)) THEN null ELSE cast(numdates#94353978 as int) END AS numdates#94354240, CASE WHEN (annual_bmret#94353979 = null) THEN null ELSE annual_bmret#94353979 END AS annual_bmret#94354241, CASE WHEN ((annual_ret#94353980 = NA) OR (annual_ret#94353980 = null)) THEN null ELSE cast(annual_ret#94353980 as float) END AS annual_ret#94354242, CASE WHEN ((std_ret#94353981 = NA) OR (std_ret#94353981 = null)) THEN null ELSE cast(std_ret#94353981 as float) END AS std_ret#94354243, CASE WHEN ((Sharpe_ret#94353982 = NA) OR (Sharpe_ret#94353982 = null)) THEN null ELSE cast(Sharpe_ret#94353982 as float) END AS Sharpe_ret#94354244, CASE WHEN ((PctPos_ret#94353983 = NA) OR (PctPos_ret#94353983 = null)) THEN null ELSE cast(PctPos_ret#94353983 as float) END AS PctPos_ret#94354262, CASE WHEN (TR_ret#94353984 = null) THEN null ELSE TR_ret#94353984 END AS TR_ret#94354263, CASE WHEN (IR_ret#94353985 = null) THEN null ELSE IR_ret#94353985 END AS IR_ret#94354264, CASE WHEN ((annual_resret#94353986 = NA) OR (annual_resret#94353986 = null)) THEN null ELSE cast(annual_resret#94353986 as float) END AS annual_resret#94354276, CASE WHEN ((std_resret#94353987 = NA) OR (std_resret#94353987 = null)) THEN null ELSE cast(std_resret#94353987 as float) END AS std_resret#94354277, CASE WHEN ((Sharpe_resret#94353988 = NA) OR (Sharpe_resret#94353988 = null)) THEN null ELSE cast(Sharpe_resret#94353988 as float) END AS Sharpe_resret#94354280, CASE WHEN ((PctPos_resret#94353989 = NA) OR (PctPos_resret#94353989 = null)) THEN null ELSE cast(PctPos_resret#94353989 as float) END AS PctPos_resret#94354281, CASE WHEN (TR_resret#94353990 = null) THEN null ELSE TR_resret#94353990 END AS TR_resret#94354282, CASE WHEN (IR_resret#94353991 = null) THEN null ELSE IR_resret#94353991 END AS IR_resret#94354283, CASE WHEN ((annual_retnet#94353992 = NA) OR (annual_retnet#94353992 = null)) THEN null ELSE cast(annual_retnet#94353992 as float) END AS annual_retnet#94354284, CASE WHEN ((std_retnet#94353993 = NA) OR (std_retnet#94353993 = null)) THEN null ELSE cast(std_retnet#94353993 as float) END AS std_retnet#94354285, CASE WHEN ((Sharpe_retnet#94353994 = NA) OR (Sharpe_retnet#94353994 = null)) THEN null ELSE cast(Sharpe_retnet#94353994 as float) END AS Sharpe_retnet#94354286, CASE WHEN ((PctPos_retnet#94353995 = NA) OR (PctPos_retnet#94353995 = null)) THEN null ELSE cast(PctPos_retnet#94353995 as float) END AS PctPos_retnet#94354287, CASE WHEN (TR_retnet#94353996 = null) THEN null ELSE TR_retnet#94353996 END AS TR_retnet#94354288, CASE WHEN (IR_retnet#94353997 = null) THEN null ELSE IR_retnet#94353997 END AS IR_retnet#94354289, ... 2 more fields]
            :                    +- FileScan csv [cap#94353974,retIC#94353975,resretIC#94353976,numcos#94353977,numdates#94353978,annual_bmret#94353979,annual_ret#94353980,std_ret#94353981,Sharpe_ret#94353982,PctPos_ret#94353983,TR_ret#94353984,IR_ret#94353985,annual_resret#94353986,std_resret#94353987,Sharpe_resret#94353988,PctPos_resret#94353989,TR_resret#94353990,IR_resret#94353991,annual_retnet#94353992,std_retnet#94353993,Sharpe_retnet#94353994,PctPos_retnet#94353995,TR_retnet#94353996,IR_retnet#94353997,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/rankviews_history/rank..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
            +- *(2) Project [cap#94160394, description#94160396 AS cap_description#94356772, sort#94160395 AS cap_sort#94356773]
               +- *(2) Filter isnotnull(cap#94160394)
                  +- InMemoryTableScan [cap#94160394, description#94160396, sort#94160395], [isnotnull(cap#94160394)]
                        +- InMemoryRelation [cap#94160394, sort#94160395, description#94160396, universe#94160397], StorageLevel(disk, memory, deserialized, 1 replicas)
                              +- *(1) Project [CASE WHEN ((cap#94160377 = NA) OR (cap#94160377 = null)) THEN null ELSE cast(cap#94160377 as int) END AS cap#94160394, CASE WHEN (sort#94160378 = null) THEN null ELSE sort#94160378 END AS sort#94160395, CASE WHEN (description#94160379 = null) THEN null ELSE description#94160379 END AS description#94160396, CASE WHEN ((universe#94160380 = NA) OR (universe#94160380 = null)) THEN null ELSE cast(universe#94160380 as int) END AS universe#94160397]
                                 +- FileScan csv [cap#94160377,sort#94160378,description#94160379,universe#94160380] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/curate/curate_cap.csv], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,sort:string,description:string,universe:string>
,None), [cap_sort#94356773 ASC NULLS FIRST]

(3) InMemoryTableScan
Output [2]: [cap#94354236, turnover#94354290]
Arguments: [cap#94354236, turnover#94354290], [isnotnull(cap#94354236)]

(4) InMemoryRelation
Arguments: [cap#94354236, retIC#94354237, resretIC#94354238, numcos#94354239, numdates#94354240, annual_bmret#94354241, annual_ret#94354242, std_ret#94354243, Sharpe_ret#94354244, PctPos_ret#94354262, TR_ret#94354263, IR_ret#94354264, annual_resret#94354276, std_resret#94354277, Sharpe_resret#94354280, PctPos_resret#94354281, TR_resret#94354282, IR_resret#94354283, annual_retnet#94354284, std_retnet#94354285, Sharpe_retnet#94354286, PctPos_retnet#94354287, TR_retnet#94354288, IR_retnet#94354289, ... 2 more fields], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN ((cap#94353974 = NA) OR (cap#94353974 = null)) THEN null ELSE cast(cap#94353974 as float) END AS cap#94354236, CASE WHEN ((retIC#94353975 = NA) OR (retIC#94353975 = null)) THEN null ELSE cast(retIC#94353975 as float) END AS retIC#94354237, CASE WHEN ((resretIC#94353976 = NA) OR (resretIC#94353976 = null)) THEN null ELSE cast(resretIC#94353976 as float) END AS resretIC#94354238, CASE WHEN ((numcos#94353977 = NA) OR (numcos#94353977 = null)) THEN null ELSE cast(numcos#94353977 as float) END AS numcos#94354239, CASE WHEN ((numdates#94353978 = NA) OR (numdates#94353978 = null)) THEN null ELSE cast(numdates#94353978 as int) END AS numdates#94354240, CASE WHEN (annual_bmret#94353979 = null) THEN null ELSE annual_bmret#94353979 END AS annual_bmret#94354241, CASE WHEN ((annual_ret#94353980 = NA) OR (annual_ret#94353980 = null)) THEN null ELSE cast(annual_ret#94353980 as float) END AS annual_ret#94354242, CASE WHEN ((std_ret#94353981 = NA) OR (std_ret#94353981 = null)) THEN null ELSE cast(std_ret#94353981 as float) END AS std_ret#94354243, CASE WHEN ((Sharpe_ret#94353982 = NA) OR (Sharpe_ret#94353982 = null)) THEN null ELSE cast(Sharpe_ret#94353982 as float) END AS Sharpe_ret#94354244, CASE WHEN ((PctPos_ret#94353983 = NA) OR (PctPos_ret#94353983 = null)) THEN null ELSE cast(PctPos_ret#94353983 as float) END AS PctPos_ret#94354262, CASE WHEN (TR_ret#94353984 = null) THEN null ELSE TR_ret#94353984 END AS TR_ret#94354263, CASE WHEN (IR_ret#94353985 = null) THEN null ELSE IR_ret#94353985 END AS IR_ret#94354264, CASE WHEN ((annual_resret#94353986 = NA) OR (annual_resret#94353986 = null)) THEN null ELSE cast(annual_resret#94353986 as float) END AS annual_resret#94354276, CASE WHEN ((std_resret#94353987 = NA) OR (std_resret#94353987 = null)) THEN null ELSE cast(std_resret#94353987 as float) END AS std_resret#94354277, CASE WHEN ((Sharpe_resret#94353988 = NA) OR (Sharpe_resret#94353988 = null)) THEN null ELSE cast(Sharpe_resret#94353988 as float) END AS Sharpe_resret#94354280, CASE WHEN ((PctPos_resret#94353989 = NA) OR (PctPos_resret#94353989 = null)) THEN null ELSE cast(PctPos_resret#94353989 as float) END AS PctPos_resret#94354281, CASE WHEN (TR_resret#94353990 = null) THEN null ELSE TR_resret#94353990 END AS TR_resret#94354282, CASE WHEN (IR_resret#94353991 = null) THEN null ELSE IR_resret#94353991 END AS IR_resret#94354283, CASE WHEN ((annual_retnet#94353992 = NA) OR (annual_retnet#94353992 = null)) THEN null ELSE cast(annual_retnet#94353992 as float) END AS annual_retnet#94354284, CASE WHEN ((std_retnet#94353993 = NA) OR (std_retnet#94353993 = null)) THEN null ELSE cast(std_retnet#94353993 as float) END AS std_retnet#94354285, CASE WHEN ((Sharpe_retnet#94353994 = NA) OR (Sharpe_retnet#94353994 = null)) THEN null ELSE cast(Sharpe_retnet#94353994 as float) END AS Sharpe_retnet#94354286, CASE WHEN ((PctPos_retnet#94353995 = NA) OR (PctPos_retnet#94353995 = null)) THEN null ELSE cast(PctPos_retnet#94353995 as float) END AS PctPos_retnet#94354287, CASE WHEN (TR_retnet#94353996 = null) THEN null ELSE TR_retnet#94353996 END AS TR_retnet#94354288, CASE WHEN (IR_retnet#94353997 = null) THEN null ELSE IR_retnet#94353997 END AS IR_retnet#94354289, ... 2 more fields]
+- FileScan csv [cap#94353974,retIC#94353975,resretIC#94353976,numcos#94353977,numdates#94353978,annual_bmret#94353979,annual_ret#94353980,std_ret#94353981,Sharpe_ret#94353982,PctPos_ret#94353983,TR_ret#94353984,IR_ret#94353985,annual_resret#94353986,std_resret#94353987,Sharpe_resret#94353988,PctPos_resret#94353989,TR_resret#94353990,IR_resret#94353991,annual_retnet#94353992,std_retnet#94353993,Sharpe_retnet#94353994,PctPos_retnet#94353995,TR_retnet#94353996,IR_retnet#94353997,... 2 more fields] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/rankviews_history/rank..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,retIC:string,resretIC:string,numcos:string,numdates:string,annual_bmret:string,...
,None)

(5) Scan csv 
Output [26]: [cap#94353974, retIC#94353975, resretIC#94353976, numcos#94353977, numdates#94353978, annual_bmret#94353979, annual_ret#94353980, std_ret#94353981, Sharpe_ret#94353982, PctPos_ret#94353983, TR_ret#94353984, IR_ret#94353985, annual_resret#94353986, std_resret#94353987, Sharpe_resret#94353988, PctPos_resret#94353989, TR_resret#94353990, IR_resret#94353991, annual_retnet#94353992, std_retnet#94353993, Sharpe_retnet#94353994, PctPos_retnet#94353995, TR_retnet#94353996, IR_retnet#94353997, turnover#94353998, coverage#94353999]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/output/rankviews_history/rankviews/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#94353974 = NA) OR (cap#94353974 = null)) THEN null ELSE cast(cap#94353974 as float) END AS cap#94354236, CASE WHEN ((retIC#94353975 = NA) OR (retIC#94353975 = null)) THEN null ELSE cast(retIC#94353975 as float) END AS retIC#94354237, CASE WHEN ((resretIC#94353976 = NA) OR (resretIC#94353976 = null)) THEN null ELSE cast(resretIC#94353976 as float) END AS resretIC#94354238, CASE WHEN ((numcos#94353977 = NA) OR (numcos#94353977 = null)) THEN null ELSE cast(numcos#94353977 as float) END AS numcos#94354239, CASE WHEN ((numdates#94353978 = NA) OR (numdates#94353978 = null)) THEN null ELSE cast(numdates#94353978 as int) END AS numdates#94354240, CASE WHEN (annual_bmret#94353979 = null) THEN null ELSE annual_bmret#94353979 END AS annual_bmret#94354241, CASE WHEN ((annual_ret#94353980 = NA) OR (annual_ret#94353980 = null)) THEN null ELSE cast(annual_ret#94353980 as float) END AS annual_ret#94354242, CASE WHEN ((std_ret#94353981 = NA) OR (std_ret#94353981 = null)) THEN null ELSE cast(std_ret#94353981 as float) END AS std_ret#94354243, CASE WHEN ((Sharpe_ret#94353982 = NA) OR (Sharpe_ret#94353982 = null)) THEN null ELSE cast(Sharpe_ret#94353982 as float) END AS Sharpe_ret#94354244, CASE WHEN ((PctPos_ret#94353983 = NA) OR (PctPos_ret#94353983 = null)) THEN null ELSE cast(PctPos_ret#94353983 as float) END AS PctPos_ret#94354262, CASE WHEN (TR_ret#94353984 = null) THEN null ELSE TR_ret#94353984 END AS TR_ret#94354263, CASE WHEN (IR_ret#94353985 = null) THEN null ELSE IR_ret#94353985 END AS IR_ret#94354264, CASE WHEN ((annual_resret#94353986 = NA) OR (annual_resret#94353986 = null)) THEN null ELSE cast(annual_resret#94353986 as float) END AS annual_resret#94354276, CASE WHEN ((std_resret#94353987 = NA) OR (std_resret#94353987 = null)) THEN null ELSE cast(std_resret#94353987 as float) END AS std_resret#94354277, CASE WHEN ((Sharpe_resret#94353988 = NA) OR (Sharpe_resret#94353988 = null)) THEN null ELSE cast(Sharpe_resret#94353988 as float) END AS Sharpe_resret#94354280, CASE WHEN ((PctPos_resret#94353989 = NA) OR (PctPos_resret#94353989 = null)) THEN null ELSE cast(PctPos_resret#94353989 as float) END AS PctPos_resret#94354281, CASE WHEN (TR_resret#94353990 = null) THEN null ELSE TR_resret#94353990 END AS TR_resret#94354282, CASE WHEN (IR_resret#94353991 = null) THEN null ELSE IR_resret#94353991 END AS IR_resret#94354283, CASE WHEN ((annual_retnet#94353992 = NA) OR (annual_retnet#94353992 = null)) THEN null ELSE cast(annual_retnet#94353992 as float) END AS annual_retnet#94354284, CASE WHEN ((std_retnet#94353993 = NA) OR (std_retnet#94353993 = null)) THEN null ELSE cast(std_retnet#94353993 as float) END AS std_retnet#94354285, CASE WHEN ((Sharpe_retnet#94353994 = NA) OR (Sharpe_retnet#94353994 = null)) THEN null ELSE cast(Sharpe_retnet#94353994 as float) END AS Sharpe_retnet#94354286, CASE WHEN ((PctPos_retnet#94353995 = NA) OR (PctPos_retnet#94353995 = null)) THEN null ELSE cast(PctPos_retnet#94353995 as float) END AS PctPos_retnet#94354287, CASE WHEN (TR_retnet#94353996 = null) THEN null ELSE TR_retnet#94353996 END AS TR_retnet#94354288, CASE WHEN (IR_retnet#94353997 = null) THEN null ELSE IR_retnet#94353997 END AS IR_retnet#94354289, CASE WHEN ((turnover#94353998 = NA) OR (turnover#94353998 = null)) THEN null ELSE cast(turnover#94353998 as float) END AS turnover#94354290, CASE WHEN ((coverage#94353999 = NA) OR (coverage#94353999 = null)) THEN null ELSE cast(coverage#94353999 as float) END AS coverage#94354291]
Input [26]: [cap#94353974, retIC#94353975, resretIC#94353976, numcos#94353977, numdates#94353978, annual_bmret#94353979, annual_ret#94353980, std_ret#94353981, Sharpe_ret#94353982, PctPos_ret#94353983, TR_ret#94353984, IR_ret#94353985, annual_resret#94353986, std_resret#94353987, Sharpe_resret#94353988, PctPos_resret#94353989, TR_resret#94353990, IR_resret#94353991, annual_retnet#94353992, std_retnet#94353993, Sharpe_retnet#94353994, PctPos_retnet#94353995, TR_retnet#94353996, IR_retnet#94353997, turnover#94353998, coverage#94353999]

(7) Filter [codegen id : 1]
Input [2]: [cap#94354236, turnover#94354290]
Condition : isnotnull(cap#94354236)

(8) BroadcastExchange
Input [2]: [cap#94354236, turnover#94354290]
Arguments: HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7533662]

(9) InMemoryTableScan
Output [3]: [cap#94160394, description#94160396, sort#94160395]
Arguments: [cap#94160394, description#94160396, sort#94160395], [isnotnull(cap#94160394)]

(10) InMemoryRelation
Arguments: [cap#94160394, sort#94160395, description#94160396, universe#94160397], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN ((cap#94160377 = NA) OR (cap#94160377 = null)) THEN null ELSE cast(cap#94160377 as int) END AS cap#94160394, CASE WHEN (sort#94160378 = null) THEN null ELSE sort#94160378 END AS sort#94160395, CASE WHEN (description#94160379 = null) THEN null ELSE description#94160379 END AS description#94160396, CASE WHEN ((universe#94160380 = NA) OR (universe#94160380 = null)) THEN null ELSE cast(universe#94160380 as int) END AS universe#94160397]
+- FileScan csv [cap#94160377,sort#94160378,description#94160379,universe#94160380] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/curate/curate_cap.csv], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<cap:string,sort:string,description:string,universe:string>
,None)

(11) Scan csv 
Output [4]: [cap#94160377, sort#94160378, description#94160379, universe#94160380]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/curate/curate_cap.csv]
ReadSchema: struct<cap:string,sort:string,description:string,universe:string>

(12) Project [codegen id : 1]
Output [4]: [CASE WHEN ((cap#94160377 = NA) OR (cap#94160377 = null)) THEN null ELSE cast(cap#94160377 as int) END AS cap#94160394, CASE WHEN (sort#94160378 = null) THEN null ELSE sort#94160378 END AS sort#94160395, CASE WHEN (description#94160379 = null) THEN null ELSE description#94160379 END AS description#94160396, CASE WHEN ((universe#94160380 = NA) OR (universe#94160380 = null)) THEN null ELSE cast(universe#94160380 as int) END AS universe#94160397]
Input [4]: [cap#94160377, sort#94160378, description#94160379, universe#94160380]

(13) Filter
Input [3]: [cap#94160394, description#94160396, sort#94160395]
Condition : isnotnull(cap#94160394)

(14) Project
Output [3]: [cap#94160394, description#94160396 AS cap_description#94356772, sort#94160395 AS cap_sort#94356773]
Input [3]: [cap#94160394, description#94160396, sort#94160395]

(15) BroadcastHashJoin [codegen id : 2]
Left keys [1]: [knownfloatingpointnormalized(normalizenanandzero(cap#94354236))]
Right keys [1]: [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))]
Join condition: None

(16) Project [codegen id : 2]
Output [3]: [turnover#94354290, cap_description#94356772 AS cap#94356862, cap_sort#94356773]
Input [5]: [cap#94354236, turnover#94354290, cap#94160394, cap_description#94356772, cap_sort#94356773]

(17) Exchange
Input [3]: [turnover#94354290, cap#94356862, cap_sort#94356773]
Arguments: rangepartitioning(cap_sort#94356773 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7533670]

(18) Sort [codegen id : 3]
Input [3]: [turnover#94354290, cap#94356862, cap_sort#94356773]
Arguments: [cap_sort#94356773 ASC NULLS FIRST], true, 0

(19) Project [codegen id : 3]
Output [3]: [cap#94356862, turnover#94354290, (1.0 / cast(turnover#94354290 as double)) AS days_hold#94356890]
Input [3]: [turnover#94354290, cap#94356862, cap_sort#94356773]

(20) CollectLimit
Input [3]: [cap#94356862, turnover#94354290, days_hold#94356890]
Arguments: 1000000