特征工程优化

spark/featureEng.py

@@ -385,7 +385,7 @@ def getClickSql(start, end):
             select partition_date,cl_id,business_id as card_id,time_stamp,page_stay
             from online.bl_hdfs_maidian_updates
             where action = 'page_view'
-            AND partition_date>='{startDay}' and partition_date<'{endDay}'
+            AND partition_date>='{startDay}' and partition_date<='{endDay}'
             AND page_name='welfare_detail'
             -- AND page_stay>=1
             AND cl_id is not null
@@ -431,7 +431,7 @@ def getExposureSql(start, end):
         (	--新首页卡片曝光
             SELECT partition_date,cl_id,card_id,time_stamp
             FROM online.ml_community_precise_exposure_detail
-            where partition_date>='{startDay}' and partition_date<'{endDay}'
+            where partition_date>='{startDay}' and partition_date<='{endDay}'
             and action in ('page_precise_exposure','home_choiceness_card_exposure')
             and cl_id IS NOT NULL
             and card_id IS NOT NULL