add creative feature

src/main/java/examples/dataloader/AdSampleConstructor.java

@@ -140,39 +140,39 @@ public class AdSampleConstructor {
 
         //TODO  CREATIVE 维度  需要在样本中补齐
         AdActionFeature creative1dayFeature = new AdActionFeature();
-        creative1dayFeature.setAdView(record.getString("ad_view_1day"));
-        creative1dayFeature.setAdClick(record.getString("ad_click_1day"));
-        creative1dayFeature.setAdConversion(record.getString("ad_conversion_1day"));
-        creative1dayFeature.setCtr(record.getString("ad_ctr_1day"));
-        creative1dayFeature.setCvr(record.getString("ad_cvr_1day"));
+        creative1dayFeature.setAdView(record.getString("view_creative_1day"));
+        creative1dayFeature.setAdClick(record.getString("click_creative_1day"));
+        creative1dayFeature.setAdConversion(record.getString("conversion_creative_1day"));
+        creative1dayFeature.setCtr(record.getString("ctr_creative_1day"));
+        creative1dayFeature.setCvr(record.getString("cvr_creative_1day"));
         itemFeature.setCreative_1day_cnt_features(creative1dayFeature);
 
         // 3day features
         AdActionFeature creative3dayFeature = new AdActionFeature();
-        creative3dayFeature.setAdView(record.getString("ad_view_3day"));
-        creative3dayFeature.setAdClick(record.getString("ad_click_3day"));
-        creative3dayFeature.setAdConversion(record.getString("ad_conversion_3day"));
-        creative3dayFeature.setCtr(record.getString("ad_ctr_3day"));
-        creative3dayFeature.setCvr(record.getString("ad_cvr_3day"));
+        creative3dayFeature.setAdView(record.getString("view_creative_3day"));
+        creative3dayFeature.setAdClick(record.getString("click_creative_3day"));
+        creative3dayFeature.setAdConversion(record.getString("conversion_creative_3day"));
+        creative3dayFeature.setCtr(record.getString("ctr_creative_3day"));
+        creative3dayFeature.setCvr(record.getString("cvr_creative_3day"));
         itemFeature.setCreative_3day_cnt_features(creative3dayFeature);
 
 
         // 7day features
         AdActionFeature creative7dayFeature = new AdActionFeature();
-        creative7dayFeature.setAdView(record.getString("ad_view_7day"));
-        creative7dayFeature.setAdClick(record.getString("ad_click_7day"));
-        creative7dayFeature.setAdConversion(record.getString("ad_conversion_7day"));
-        creative7dayFeature.setCtr(record.getString("ad_ctr_7day"));
-        creative7dayFeature.setCvr(record.getString("ad_cvr_7day"));
+        creative7dayFeature.setAdView(record.getString("view_creative_7day"));
+        creative7dayFeature.setAdClick(record.getString("click_creative_7day"));
+        creative7dayFeature.setAdConversion(record.getString("conversion_creative_7day"));
+        creative7dayFeature.setCtr(record.getString("ctr_creative_7day"));
+        creative7dayFeature.setCvr(record.getString("cvr_creative_7day"));
         itemFeature.setCreative_7day_cnt_features(creative7dayFeature);
 
         // 3month features
         AdActionFeature creative3MonthFeature = new AdActionFeature();
-        creative3MonthFeature.setAdView(record.getString("ad_view_3month"));
-        creative3MonthFeature.setAdClick(record.getString("ad_click_3month"));
-        creative3MonthFeature.setAdConversion(record.getString("ad_conversion_3month"));
-        creative3MonthFeature.setCtr(record.getString("ad_ctr_3month"));
-        creative3MonthFeature.setCvr(record.getString("ad_cvr_3month"));
+        creative3MonthFeature.setAdView(record.getString("view_creative_3month"));
+        creative3MonthFeature.setAdClick(record.getString("click_creative_3month"));
+        creative3MonthFeature.setAdConversion(record.getString("conversion_creative_3month"));
+        creative3MonthFeature.setCtr(record.getString("ctr_creative_3month"));
+        creative3MonthFeature.setCvr(record.getString("cvr_creative_3month"));
         itemFeature.setCreative_3month_cnt_features(creative3MonthFeature);
 
 

src/main/java/examples/sparksql/SparkAdFeaToRedisLoader.java

@@ -53,7 +53,6 @@ public class SparkAdFeaToRedisLoader {
     }
 
 
-
     static class RecordsToAdRedisKV implements Function2<Record, TableSchema, List<String>> {
         @Override
         public List<String> call(Record record, TableSchema schema) throws Exception {
@@ -73,9 +72,10 @@ public class SparkAdFeaToRedisLoader {
         @Override
         public List<String> call(Record record, TableSchema schema) throws Exception {
             UserAdFeature userFeature = AdRedisFeatureConstructor.constructUserFeature(record);
+            List<String> kv = new ArrayList<String>();
             String key = String.format(userKeyFormat, userFeature.getKey());
+
             String value = userFeature.getValue();
-            List<String> kv = new ArrayList<String>();
             kv.add(key);
             kv.add(value);
             return kv;