all

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

@@ -207,7 +207,7 @@ object makedata_02_writeredis {
     val mid = record.getString(userKey)
     val reqContext: RequestContextOffline = new RequestContextOffline()
     reqContext.putUserFeature(record)
-    reqContext.featureMap.put("mid", mid)
+    // reqContext.featureMap.put("mid", mid)
     val gson = (new GsonBuilder).serializeSpecialFloatingPointValues.create
     val value = gson.toJson(reqContext.featureMap)
     (mid, value, reqContext.featureMap.size())
@@ -239,7 +239,7 @@ object makedata_02_writeredis {
     //------修复完成---------
 
     reqContext.putItemFeature(record)
-    reqContext.featureMap.put("videoid", videoid)
+     reqContext.featureMap.put("videoid", videoid)
 
     val gson = (new GsonBuilder).serializeSpecialFloatingPointValues.create
     val value = gson.toJson(reqContext.featureMap)