zhangbo 1 年之前
父节点
当前提交
63f582fd16
共有 1 个文件被更改,包括 4 次插入2 次删除
  1. 4 2
      src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

+ 4 - 2
src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -144,10 +144,12 @@ object makedata_02_writeredis {
       ""
     }
     if (i_title_len.nonEmpty){
-      reqContext.featureMap.put("i_title_len", reqContext.bucketRatioFeature(i_title_len.toDouble))
+      val d = reqContext.bucketRatioFeature(i_title_len.toDouble)
+      reqContext.featureMap.put("i_title_len", d.asInstanceOf[Object])
     }
     if (i_days_since_upload.nonEmpty) {
-      reqContext.featureMap.put("i_days_since_upload", reqContext.bucketRatioFeature(i_days_since_upload.toDouble))
+      val d = reqContext.bucketRatioFeature(i_days_since_upload.toDouble)
+      reqContext.featureMap.put("i_days_since_upload", d.asInstanceOf[Object])
     }
     //------修复完成---------