all

src/main/java/examples/dataloader/RequestContextOffline.java

@@ -72,9 +72,9 @@ public class RequestContextOffline extends RequestContext {
                 return;
             case "double":
                 if ("cnt".equals(cntOrRate)){
-                    featureMap.put(key, this.bucketRatioFeature(Double.valueOf(value)));
+                    featureMap.put(key, String.valueOf(this.bucketRatioFeature(Double.valueOf(value))));
                 }else if ("rate".equals(cntOrRate)){
-                    featureMap.put(key, this.ceilLog(Double.valueOf(value)));
+                    featureMap.put(key, String.valueOf(this.ceilLog(Double.valueOf(value))));
                 }
                 return;
             case "int":

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -151,17 +151,14 @@ object makedata_02_writeredis {
     }
     if (i_title_len.nonEmpty){
       val d = reqContext.bucketRatioFeature(i_title_len.toDouble)
-      reqContext.featureMap.put("i_title_len", d.asInstanceOf[Object])
+      reqContext.featureMap.put("i_title_len", d.toString)
     }
     if (i_days_since_upload.nonEmpty) {
       val d = reqContext.bucketRatioFeature(i_days_since_upload.toDouble)
-      reqContext.featureMap.put("i_days_since_upload", d.asInstanceOf[Object])
+      reqContext.featureMap.put("i_days_since_upload", d.toString)
     }
     //------修复完成---------
 
-
-
-
     reqContext.putItemFeature(record)
     reqContext.featureMap.put("videoid", videoid)