== Physical Plan ==
CollectLimit (21)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- * Project (20)
+- * Sort (19)
+- Exchange (18)
+- * Project (17)
+- * BroadcastHashJoin Inner BuildLeft (16)
:- BroadcastExchange (9)
: +- * Filter (8)
: +- * ColumnarToRow (7)
: +- InMemoryTableScan (3)
: +- InMemoryRelation (4)
: +- * Project (6)
: +- Scan csv (5)
+- * Project (15)
+- * Filter (14)
+- InMemoryTableScan (10)
+- InMemoryRelation (11)
+- * Project (13)
+- Scan csv (12)
(1) InMemoryTableScan
Output [3]: [cap#93999389, turnover#93996266, days_hold#93999423]
Arguments: [cap#93999389, turnover#93996266, days_hold#93999423]
(2) InMemoryRelation
Arguments: [cap#93999389, turnover#93996266, days_hold#93999423], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(3) Project [cap#93999389, turnover#93996266, (1.0 / cast(turnover#93996266 as double)) AS days_hold#93999423]
+- *(3) Sort [cap_sort#93999300 ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(cap_sort#93999300 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7505210]
+- *(2) Project [turnover#93996266, cap_description#93999299 AS cap#93999389, cap_sort#93999300]
+- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#93996101))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#93880528 as float)))], Inner, BuildLeft, false
:- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7505202]
: +- *(1) Filter isnotnull(cap#93996101)
: +- *(1) ColumnarToRow
: +- InMemoryTableScan [cap#93996101, turnover#93996266], [isnotnull(cap#93996101)]
: +- 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,...
+- *(2) Project [cap#93880528, description#93880533 AS cap_description#93999299, sort#93880531 AS cap_sort#93999300]
+- *(2) Filter isnotnull(cap#93880528)
+- InMemoryTableScan [cap#93880528, description#93880533, sort#93880531], [isnotnull(cap#93880528)]
+- InMemoryRelation [cap#93880528, sort#93880531, description#93880533, universe#93880535], StorageLevel(disk, memory, deserialized, 1 replicas)
+- *(1) Project [CASE WHEN ((cap#93880496 = NA) OR (cap#93880496 = null)) THEN null ELSE cast(cap#93880496 as int) END AS cap#93880528, CASE WHEN (sort#93880498 = null) THEN null ELSE sort#93880498 END AS sort#93880531, CASE WHEN (description#93880500 = null) THEN null ELSE description#93880500 END AS description#93880533, CASE WHEN ((universe#93880502 = NA) OR (universe#93880502 = null)) THEN null ELSE cast(universe#93880502 as int) END AS universe#93880535]
+- FileScan csv [cap#93880496,sort#93880498,description#93880500,universe#93880502] 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#93999300 ASC NULLS FIRST]
(3) InMemoryTableScan
Output [2]: [cap#93996101, turnover#93996266]
Arguments: [cap#93996101, turnover#93996266], [isnotnull(cap#93996101)]
(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 : 1]
Input [2]: [cap#93996101, turnover#93996266]
(8) Filter [codegen id : 1]
Input [2]: [cap#93996101, turnover#93996266]
Condition : isnotnull(cap#93996101)
(9) BroadcastExchange
Input [2]: [cap#93996101, turnover#93996266]
Arguments: HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7505202]
(10) InMemoryTableScan
Output [3]: [cap#93880528, description#93880533, sort#93880531]
Arguments: [cap#93880528, description#93880533, sort#93880531], [isnotnull(cap#93880528)]
(11) InMemoryRelation
Arguments: [cap#93880528, sort#93880531, description#93880533, universe#93880535], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN ((cap#93880496 = NA) OR (cap#93880496 = null)) THEN null ELSE cast(cap#93880496 as int) END AS cap#93880528, CASE WHEN (sort#93880498 = null) THEN null ELSE sort#93880498 END AS sort#93880531, CASE WHEN (description#93880500 = null) THEN null ELSE description#93880500 END AS description#93880533, CASE WHEN ((universe#93880502 = NA) OR (universe#93880502 = null)) THEN null ELSE cast(universe#93880502 as int) END AS universe#93880535]
+- FileScan csv [cap#93880496,sort#93880498,description#93880500,universe#93880502] 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)
(12) Scan csv
Output [4]: [cap#93880496, sort#93880498, description#93880500, universe#93880502]
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>
(13) Project [codegen id : 1]
Output [4]: [CASE WHEN ((cap#93880496 = NA) OR (cap#93880496 = null)) THEN null ELSE cast(cap#93880496 as int) END AS cap#93880528, CASE WHEN (sort#93880498 = null) THEN null ELSE sort#93880498 END AS sort#93880531, CASE WHEN (description#93880500 = null) THEN null ELSE description#93880500 END AS description#93880533, CASE WHEN ((universe#93880502 = NA) OR (universe#93880502 = null)) THEN null ELSE cast(universe#93880502 as int) END AS universe#93880535]
Input [4]: [cap#93880496, sort#93880498, description#93880500, universe#93880502]
(14) Filter
Input [3]: [cap#93880528, description#93880533, sort#93880531]
Condition : isnotnull(cap#93880528)
(15) Project
Output [3]: [cap#93880528, description#93880533 AS cap_description#93999299, sort#93880531 AS cap_sort#93999300]
Input [3]: [cap#93880528, description#93880533, sort#93880531]
(16) BroadcastHashJoin [codegen id : 2]
Left keys [1]: [knownfloatingpointnormalized(normalizenanandzero(cap#93996101))]
Right keys [1]: [knownfloatingpointnormalized(normalizenanandzero(cast(cap#93880528 as float)))]
Join condition: None
(17) Project [codegen id : 2]
Output [3]: [turnover#93996266, cap_description#93999299 AS cap#93999389, cap_sort#93999300]
Input [5]: [cap#93996101, turnover#93996266, cap#93880528, cap_description#93999299, cap_sort#93999300]
(18) Exchange
Input [3]: [turnover#93996266, cap#93999389, cap_sort#93999300]
Arguments: rangepartitioning(cap_sort#93999300 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7505210]
(19) Sort [codegen id : 3]
Input [3]: [turnover#93996266, cap#93999389, cap_sort#93999300]
Arguments: [cap_sort#93999300 ASC NULLS FIRST], true, 0
(20) Project [codegen id : 3]
Output [3]: [cap#93999389, turnover#93996266, (1.0 / cast(turnover#93996266 as double)) AS days_hold#93999423]
Input [3]: [turnover#93996266, cap#93999389, cap_sort#93999300]
(21) CollectLimit
Input [3]: [cap#93999389, turnover#93996266, days_hold#93999423]
Arguments: 1000000