特征调整

src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureTransform.java

@@ -353,6 +353,9 @@ public class FeatureTransform {
         }
         for (String period : hourPeriods) {
             double exp = getOneInfo("exp_" + period, infoMap);
+            if (!FeatureUtils.greaterThanZero(exp)) {
+                continue;
+            }
             double is_share = getOneInfo("is_share_" + period, infoMap);
             double share_cnt = getOneInfo("share_cnt_" + period, infoMap);
             double is_return_1 = getOneInfo("is_return_1_" + period, infoMap);

src/main/scala/com/aliyun/odps/spark/examples/myUtils/FeatureUtils.java

@@ -147,6 +147,10 @@ public class FeatureUtils {
         return (numerator_1 - numerator_2) / denominator;
     }
 
+    public static boolean greaterThanZero(double value) {
+        return value > 1E-8;
+    }
+
     public static Double[] funcC34567ForTagsNew(String tags, String title) {
         String[] tagsList = tags.split(",");
         int d1 = 0;